org.wso2.carbon.analytics.eventtable

Class AnalyticsEventTable.AnalyticsTableOperator

java.lang.Object

org.wso2.carbon.analytics.eventtable.AnalyticsEventTable.AnalyticsTableOperator

All Implemented Interfaces:

org.wso2.siddhi.core.util.collection.operator.Finder, org.wso2.siddhi.core.util.collection.operator.Operator

Enclosing class:

AnalyticsEventTable

public class AnalyticsEventTable.AnalyticsTableOperator
extends Object
implements org.wso2.siddhi.core.util.collection.operator.Operator

Analytics table Operator implementation.

Constructor Summary

Constructors

Constructor and Description

AnalyticsEventTable.AnalyticsTableOperator(int tenantId, String tableName, List<org.wso2.siddhi.query.api.definition.Attribute> attrs, 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)

Method Summary

Methods

Modifier and Type	Method and Description
org.wso2.siddhi.core.util.collection.operator.Finder	cloneFinder()
boolean	contains(org.wso2.siddhi.core.event.ComplexEvent matchingEvent, Object candidateEvents)
void	delete(org.wso2.siddhi.core.event.ComplexEventChunk deletingEventChunk, Object candidateEvents)
org.wso2.siddhi.core.event.stream.StreamEvent	find(org.wso2.siddhi.core.event.ComplexEvent matchingEvent, Object candidateEvents, org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner)
void	update(org.wso2.siddhi.core.event.ComplexEventChunk updatingEventChunk, Object candidateEvents, int[] mappingPosition)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsEventTable.AnalyticsTableOperator

public AnalyticsEventTable.AnalyticsTableOperator(int tenantId,
                                          String tableName,
                                          List<org.wso2.siddhi.query.api.definition.Attribute> attrs,
                                          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)

Method Detail

cloneFinder

public org.wso2.siddhi.core.util.collection.operator.Finder cloneFinder()

Specified by:

cloneFinder in interface org.wso2.siddhi.core.util.collection.operator.Finder

contains

public boolean contains(org.wso2.siddhi.core.event.ComplexEvent matchingEvent,
               Object candidateEvents)

Specified by:

contains in interface org.wso2.siddhi.core.util.collection.operator.Finder

find

public org.wso2.siddhi.core.event.stream.StreamEvent find(org.wso2.siddhi.core.event.ComplexEvent matchingEvent,
                                                 Object candidateEvents,
                                                 org.wso2.siddhi.core.event.stream.StreamEventCloner streamEventCloner)

Specified by:

find in interface org.wso2.siddhi.core.util.collection.operator.Finder

delete

public void delete(org.wso2.siddhi.core.event.ComplexEventChunk deletingEventChunk,
          Object candidateEvents)

Specified by:

delete in interface org.wso2.siddhi.core.util.collection.operator.Operator

update

public void update(org.wso2.siddhi.core.event.ComplexEventChunk updatingEventChunk,
          Object candidateEvents,
          int[] mappingPosition)

Specified by:

update in interface org.wso2.siddhi.core.util.collection.operator.Operator