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

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.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.core.util.collection.operator.Operator	constructOperator(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)
boolean	contains(org.wso2.siddhi.core.event.state.StateEvent 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.state.StateEvent matchingEvent, org.wso2.siddhi.core.util.collection.operator.Finder finder)
Map<String,List<org.wso2.carbon.analytics.datasource.commons.Record>>	getCache()
org.wso2.siddhi.query.api.definition.TableDefinition	getTableDefinition()
void	init(org.wso2.siddhi.query.api.definition.TableDefinition tableDefinition, org.wso2.siddhi.core.event.stream.MetaStreamEvent tableMetaStreamEvent, org.wso2.siddhi.core.event.stream.StreamEventPool tableStreamEventPool, org.wso2.siddhi.core.event.stream.StreamEventCloner tableStreamEventCloner, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
boolean	isCaching()
void	overwriteOrAdd(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> overwritingOrAddingEventChunk, org.wso2.siddhi.core.util.collection.operator.Operator operator, 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, org.wso2.siddhi.core.util.collection.operator.Operator operator, 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

public AnalyticsEventTable()

Method Detail

init

public void init(org.wso2.siddhi.query.api.definition.TableDefinition tableDefinition,
                 org.wso2.siddhi.core.event.stream.MetaStreamEvent tableMetaStreamEvent,
                 org.wso2.siddhi.core.event.stream.StreamEventPool tableStreamEventPool,
                 org.wso2.siddhi.core.event.stream.StreamEventCloner tableStreamEventCloner,
                 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.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)

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.state.StateEvent 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.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)

Specified by:

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

contains

public boolean contains(org.wso2.siddhi.core.event.state.StateEvent 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<org.wso2.siddhi.core.event.state.StateEvent> updatingEventChunk,
                   org.wso2.siddhi.core.util.collection.operator.Operator operator,
                   org.wso2.siddhi.core.util.collection.UpdateAttributeMapper[] updateAttributeMappers)

Specified by:

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

overwriteOrAdd

public void overwriteOrAdd(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> overwritingOrAddingEventChunk,
                           org.wso2.siddhi.core.util.collection.operator.Operator operator,
                           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.table.EventTable

isCaching

public boolean isCaching()

getCache

public Map<String,List<org.wso2.carbon.analytics.datasource.commons.Record>> getCache()