org.wso2.carbon.analytics.eventtable

Class AnalyticsEventTable

java.lang.Object

org.wso2.carbon.analytics.eventtable.AnalyticsEventTable

All Implemented Interfaces:

org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor, org.wso2.siddhi.core.table.EventTable

public class AnalyticsEventTable
extends Object
implements org.wso2.siddhi.core.table.EventTable

This class implements the Siddhi event table interface EventTable for analytics tables.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AnalyticsEventTable.AnalyticsTableOperator Analytics table Operator implementation.

Constructor Summary

Constructors

Constructor and Description
AnalyticsEventTable()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(org.wso2.siddhi.core.event.ComplexEventChunk addingEventChunk)
org.wso2.siddhi.core.util.collection.operator.Finder	constructFinder(org.wso2.siddhi.query.api.expression.Expression expression, org.wso2.siddhi.core.event.MetaComplexEvent metaComplexEvent, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext, List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors, Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap, int matchingStreamIndex, long withinTime)
org.wso2.siddhi.core.util.collection.operator.Operator	constructOperator(org.wso2.siddhi.query.api.expression.Expression expression, org.wso2.siddhi.core.event.MetaComplexEvent metaComplexEvent, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext, List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors, Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap, int matchingStreamIndex, long withinTime)
boolean	contains(org.wso2.siddhi.core.event.ComplexEvent matchingEvent, org.wso2.siddhi.core.util.collection.operator.Finder finder)
void	delete(org.wso2.siddhi.core.event.ComplexEventChunk deletingEventChunk, org.wso2.siddhi.core.util.collection.operator.Operator operator)
org.wso2.siddhi.core.event.stream.StreamEvent	find(org.wso2.siddhi.core.event.ComplexEvent matchingEvent, org.wso2.siddhi.core.util.collection.operator.Finder finder)
org.wso2.siddhi.query.api.definition.TableDefinition	getTableDefinition()
void	init(org.wso2.siddhi.query.api.definition.TableDefinition tableDefinition, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
void	update(org.wso2.siddhi.core.event.ComplexEventChunk updatingEventChunk, org.wso2.siddhi.core.util.collection.operator.Operator operator, int[] mappingPosition)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsEventTable

public AnalyticsEventTable()

Method Detail

init

public void init(org.wso2.siddhi.query.api.definition.TableDefinition tableDefinition,
        org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)

Specified by:

init in interface org.wso2.siddhi.core.table.EventTable

constructFinder

public org.wso2.siddhi.core.util.collection.operator.Finder constructFinder(org.wso2.siddhi.query.api.expression.Expression expression,
                                                                   org.wso2.siddhi.core.event.MetaComplexEvent metaComplexEvent,
                                                                   org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext,
                                                                   List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors,
                                                                   Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap,
                                                                   int matchingStreamIndex,
                                                                   long withinTime)

Specified by:

constructFinder in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor

find

public org.wso2.siddhi.core.event.stream.StreamEvent find(org.wso2.siddhi.core.event.ComplexEvent matchingEvent,
                                                 org.wso2.siddhi.core.util.collection.operator.Finder finder)

Specified by:

find in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor

add

public void add(org.wso2.siddhi.core.event.ComplexEventChunk addingEventChunk)

Specified by:

add in interface org.wso2.siddhi.core.table.EventTable

constructOperator

public org.wso2.siddhi.core.util.collection.operator.Operator constructOperator(org.wso2.siddhi.query.api.expression.Expression expression,
                                                                       org.wso2.siddhi.core.event.MetaComplexEvent metaComplexEvent,
                                                                       org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext,
                                                                       List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors,
                                                                       Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap,
                                                                       int matchingStreamIndex,
                                                                       long withinTime)

Specified by:

constructOperator in interface org.wso2.siddhi.core.table.EventTable

contains

public boolean contains(org.wso2.siddhi.core.event.ComplexEvent matchingEvent,
               org.wso2.siddhi.core.util.collection.operator.Finder finder)

Specified by:

contains in interface org.wso2.siddhi.core.table.EventTable

delete

public void delete(org.wso2.siddhi.core.event.ComplexEventChunk deletingEventChunk,
          org.wso2.siddhi.core.util.collection.operator.Operator operator)

Specified by:

delete in interface org.wso2.siddhi.core.table.EventTable

getTableDefinition

public org.wso2.siddhi.query.api.definition.TableDefinition getTableDefinition()

Specified by:

getTableDefinition in interface org.wso2.siddhi.core.table.EventTable

update

public void update(org.wso2.siddhi.core.event.ComplexEventChunk updatingEventChunk,
          org.wso2.siddhi.core.util.collection.operator.Operator operator,
          int[] mappingPosition)

Specified by:

update in interface org.wso2.siddhi.core.table.EventTable