org.wso2.carbon.analytics.eventtable

Class AnalyticsEventTableUtils

java.lang.Object

org.wso2.carbon.analytics.eventtable.AnalyticsEventTableUtils

public class AnalyticsEventTableUtils
extends Object

Utility operations for analytics event table.

Constructor Summary

Constructors

Constructor and Description
AnalyticsEventTableUtils()

Method Summary

Modifier and Type	Method and Description
static void	deleteRecords(int tenantId, String tableName, List<org.wso2.carbon.analytics.datasource.commons.Record> records)
static List<org.wso2.carbon.analytics.datasource.commons.Record>	getAllRecords(int tenantId, String tableName)
static int	putEvents(int tenantId, String tableName, List<org.wso2.siddhi.query.api.definition.Attribute> attrs, org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.ComplexEvent> addingEventChunk)
static org.wso2.siddhi.core.event.stream.StreamEvent	recordsToStreamEvent(List<org.wso2.siddhi.query.api.definition.Attribute> attrs, List<org.wso2.carbon.analytics.datasource.commons.Record> records)
static org.wso2.siddhi.core.event.stream.StreamEvent	recordToStreamEvent(List<org.wso2.siddhi.query.api.definition.Attribute> attrs, org.wso2.carbon.analytics.datasource.commons.Record record)
static Map<String,Object>	streamEventToRecordValues(List<org.wso2.siddhi.query.api.definition.Attribute> attrs, org.wso2.siddhi.core.event.ComplexEvent event, org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AnalyticsEventTableUtils

public AnalyticsEventTableUtils()

Method Detail

putEvents

public static int putEvents(int tenantId,
                            String tableName,
                            List<org.wso2.siddhi.query.api.definition.Attribute> attrs,
                            org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.ComplexEvent> addingEventChunk)

streamEventToRecordValues

public static Map<String,Object> streamEventToRecordValues(List<org.wso2.siddhi.query.api.definition.Attribute> attrs,
                                                           org.wso2.siddhi.core.event.ComplexEvent event,
                                                           org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers)

getAllRecords

public static List<org.wso2.carbon.analytics.datasource.commons.Record> getAllRecords(int tenantId,
                                                                                      String tableName)

deleteRecords

public static void deleteRecords(int tenantId,
                                 String tableName,
                                 List<org.wso2.carbon.analytics.datasource.commons.Record> records)

recordsToStreamEvent

public static org.wso2.siddhi.core.event.stream.StreamEvent recordsToStreamEvent(List<org.wso2.siddhi.query.api.definition.Attribute> attrs,
                                                                                 List<org.wso2.carbon.analytics.datasource.commons.Record> records)

recordToStreamEvent

public static org.wso2.siddhi.core.event.stream.StreamEvent recordToStreamEvent(List<org.wso2.siddhi.query.api.definition.Attribute> attrs,
                                                                                org.wso2.carbon.analytics.datasource.commons.Record record)