public class HazelcastEventTable extends Object implements org.wso2.siddhi.core.table.EventTable
Constructor and Description |
---|
HazelcastEventTable() |
Modifier and Type | Method and Description |
---|---|
void |
add(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> 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<org.wso2.siddhi.core.event.state.StateEvent> 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) |
protected com.hazelcast.core.HazelcastInstance |
getHazelcastInstance(boolean serverMode,
String groupName,
String groupPassword,
String addresses)
Called to get the most suitable Hazelcast Instance for the given set of parameters.
|
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)
Event Table initialization method, it checks the annotation and do necessary pre configuration tasks.
|
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) |
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)
init
in interface org.wso2.siddhi.core.table.EventTable
tableDefinition
- Definition of event table.tableMetaStreamEvent
- tableStreamEventPool
- tableStreamEventCloner
- executionPlanContext
- ExecutionPlan related meta information.protected com.hazelcast.core.HazelcastInstance getHazelcastInstance(boolean serverMode, String groupName, String groupPassword, String addresses)
groupName
- Hazelcast cluster name.groupPassword
- Hazelcast cluster password.addresses
- Hazelcast node addresses ("ip1,ip2,..").public org.wso2.siddhi.query.api.definition.TableDefinition getTableDefinition()
getTableDefinition
in interface org.wso2.siddhi.core.table.EventTable
public void add(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.stream.StreamEvent> addingEventChunk)
add
in interface org.wso2.siddhi.core.table.EventTable
public void delete(org.wso2.siddhi.core.event.ComplexEventChunk<org.wso2.siddhi.core.event.state.StateEvent> deletingEventChunk, org.wso2.siddhi.core.util.collection.operator.Operator operator)
delete
in interface org.wso2.siddhi.core.table.EventTable
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)
update
in interface org.wso2.siddhi.core.table.EventTable
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)
overwriteOrAdd
in interface org.wso2.siddhi.core.table.EventTable
public boolean contains(org.wso2.siddhi.core.event.state.StateEvent matchingEvent, org.wso2.siddhi.core.util.collection.operator.Finder finder)
contains
in interface org.wso2.siddhi.core.table.EventTable
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)
find
in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor
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)
constructFinder
in interface org.wso2.siddhi.core.query.processor.stream.window.FindableProcessor
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)
constructOperator
in interface org.wso2.siddhi.core.table.EventTable
Copyright © 2018 WSO2. All rights reserved.