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

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, org.wso2.siddhi.query.api.definition.TableDefinition tableDefinition, String query)

Method Summary

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

AnalyticsTableOperator

public 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,
                              org.wso2.siddhi.query.api.definition.TableDefinition tableDefinition,
                              String query)

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