public class InMemoryTable extends Table
Modifier and Type | Class and Description |
---|---|
class |
InMemoryTable.TableState
class to store the state of table
|
siddhiAppContext, tableDefinition, tableMap
Constructor and Description |
---|
InMemoryTable() |
Modifier and Type | Method and Description |
---|---|
void |
add(ComplexEventChunk<StreamEvent> addingEventChunk) |
CompiledCondition |
compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext)
To construct a finder having the capability of finding events at the processor that corresponds to the incoming
matchingEvent and the given matching expression logic.
|
CompiledUpdateSet |
compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext)
Builds the "compiled" set clause of an update query.
|
protected void |
connectAndLoadCache() |
boolean |
contains(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
void |
delete(ComplexEventChunk<StateEvent> deletingEventChunk,
CompiledCondition compiledCondition) |
protected void |
destroy() |
protected void |
disconnect() |
StreamEvent |
find(CompiledCondition compiledCondition,
StateEvent matchingEvent) |
io.siddhi.query.api.definition.TableDefinition |
getTableDefinition() |
void |
init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
int |
size() |
void |
update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
addEvents, connectWithRetry, containsEvent, deleteEvents, find, getHandler, initTable, setIsTryingToConnectToFalse, shutdown, updateEvents, updateOrAddEvents
public void init(io.siddhi.query.api.definition.TableDefinition tableDefinition, StreamEventFactory storeEventPool, StreamEventCloner storeEventCloner, ConfigReader configReader, SiddhiAppContext siddhiAppContext, RecordTableHandler recordTableHandler)
public io.siddhi.query.api.definition.TableDefinition getTableDefinition()
getTableDefinition
in class Table
public void add(ComplexEventChunk<StreamEvent> addingEventChunk)
public void delete(ComplexEventChunk<StateEvent> deletingEventChunk, CompiledCondition compiledCondition)
public void update(ComplexEventChunk<StateEvent> updatingEventChunk, CompiledCondition compiledCondition, CompiledUpdateSet compiledUpdateSet)
public void updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk, CompiledCondition compiledCondition, CompiledUpdateSet compiledUpdateSet, AddingStreamEventExtractor addingStreamEventExtractor)
updateOrAdd
in class Table
public boolean contains(StateEvent matchingEvent, CompiledCondition compiledCondition)
protected void disconnect()
disconnect
in class Table
public StreamEvent find(CompiledCondition compiledCondition, StateEvent matchingEvent)
public CompiledCondition compileCondition(io.siddhi.query.api.expression.Expression condition, MatchingMetaInfoHolder matchingMetaInfoHolder, List<VariableExpressionExecutor> variableExpressionExecutors, Map<String,Table> tableMap, SiddhiQueryContext siddhiQueryContext)
FindableProcessor
condition
- the matching conditionmatchingMetaInfoHolder
- the meta structure of the incoming matchingEventvariableExpressionExecutors
- the list of variable ExpressionExecutors already createdtableMap
- map of event tablessiddhiQueryContext
- current siddhi query contextpublic CompiledUpdateSet compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet, MatchingMetaInfoHolder matchingMetaInfoHolder, List<VariableExpressionExecutor> variableExpressionExecutors, Map<String,Table> tableMap, SiddhiQueryContext siddhiQueryContext)
Table
compileUpdateSet
in class Table
updateSet
- the set of assignment expressions, each containing the table column to be
updated and the expression to be assigned.matchingMetaInfoHolder
- the meta structure of the incoming matchingEventvariableExpressionExecutors
- the list of variable ExpressionExecutors already createdtableMap
- map of event tablessiddhiQueryContext
- current siddhi query contextprotected void connectAndLoadCache() throws ConnectionUnavailableException
connectAndLoadCache
in class Table
ConnectionUnavailableException
public int size()
Copyright © 2019. All rights reserved.