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.util.collection.operator.MatchingMetaStateHolder matchingMetaStateHolder, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext, List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors, Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap)

Method Summary

Methods

Modifier and Type	Method and Description
org.wso2.siddhi.core.util.collection.operator.Finder	cloneFinder(String key)
boolean	contains(org.wso2.siddhi.core.event.state.StateEvent 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.state.StateEvent matchingEvent, Object candidateEvents, org.wso2.siddhi.core.event.stream.StreamEventCloner candidateEventCloner)
org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent>	overwriteOrAdd(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> overwritingOrAddingEventChunk, Object candidateEvents, org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers, org.wso2.siddhi.core.util.collection.OverwritingStreamEventExtractor overwritingStreamEventExtractor)
void	update(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> updatingEventChunk, Object candidateEvents, 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

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.util.collection.operator.MatchingMetaStateHolder matchingMetaStateHolder,
                                          org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext,
                                          List<org.wso2.siddhi.core.executor.VariableExpressionExecutor> variableExpressionExecutors,
                                          Map<String,org.wso2.siddhi.core.table.EventTable> eventTableMap)

Method Detail

cloneFinder

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

Specified by:

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

contains

public boolean contains(org.wso2.siddhi.core.event.state.StateEvent 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.state.StateEvent matchingEvent,
                                                 Object candidateEvents,
                                                 org.wso2.siddhi.core.event.stream.StreamEventCloner candidateEventCloner)

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<org.wso2.siddhi.core.event.state.StateEvent> updatingEventChunk,
          Object candidateEvents,
          org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers)

Specified by:

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

overwriteOrAdd

public org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> overwriteOrAdd(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> overwritingOrAddingEventChunk,
                                                                                                         Object candidateEvents,
                                                                                                         org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers,
                                                                                                         org.wso2.siddhi.core.util.collection.OverwritingStreamEventExtractor overwritingStreamEventExtractor)

Specified by:

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