public class InMemoryTable extends Table
Modifier and Type | Class and Description |
---|---|
class |
InMemoryTable.TableState
class to store the state of table
|
Table.OnErrorAction
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) |
boolean |
isStateful() |
protected ComplexEventChunk<StreamEvent> |
reduceEventsForUpdateOrInsert(AddingStreamEventExtractor addingStreamEventExtractor,
InMemoryCompiledCondition inMemoryCompiledCondition,
InMemoryCompiledUpdateSet compiledUpdateSet,
ComplexEventChunk<StateEvent> failedEvents) |
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, getIsConnected, getIsTryingToConnect, initTable, onAddError, onDeleteError, onUpdateError, onUpdateOrAddError, setIsConnectedToFalse, shutdown, updateEvents, updateOrAddEvents, waitWhileConnect
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
protected ComplexEventChunk<StreamEvent> reduceEventsForUpdateOrInsert(AddingStreamEventExtractor addingStreamEventExtractor, InMemoryCompiledCondition inMemoryCompiledCondition, InMemoryCompiledUpdateSet compiledUpdateSet, ComplexEventChunk<StateEvent> failedEvents)
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()
public boolean isStateful()
isStateful
in class Table
Copyright © 2021. All rights reserved.