Package | Description |
---|---|
io.siddhi.core.query.output.callback | |
io.siddhi.core.stream.input | |
io.siddhi.core.table | |
io.siddhi.core.table.record | |
io.siddhi.core.util.error.handler.model |
Constructor and Description |
---|
UpdateOrInsertTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
UpdateTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
Modifier and Type | Method and Description |
---|---|
void |
TableInputHandler.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
TableInputHandler.updateOrAdd(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryCompiledUpdateSet
Compiled update-set created for
InMemoryTable |
Modifier and Type | Method and Description |
---|---|
CompiledUpdateSet |
InMemoryTable.compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
abstract CompiledUpdateSet |
Table.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.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Table.onUpdateError(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
Exception e) |
protected void |
Table.onUpdateOrAddError(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor,
Exception e) |
void |
InMemoryTable.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
abstract void |
Table.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
Table.updateEvents(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int noOfEvents) |
void |
InMemoryTable.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
abstract void |
Table.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
CacheTable.updateOrAddAndTrimUptoMaxSize(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor,
int maxTableSize) |
void |
Table.updateOrAddEvents(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor,
int noOfEvents) |
Modifier and Type | Class and Description |
---|---|
class |
RecordTableCompiledUpdateSet
CompiledUpdateSet implementation for Record Table |
Modifier and Type | Method and Description |
---|---|
CompiledUpdateSet |
AbstractQueryableRecordTable.compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledUpdateSet |
AbstractRecordTable.compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractQueryableRecordTable.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
AbstractRecordTable.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
AbstractQueryableRecordTable.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
AbstractRecordTable.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
Modifier and Type | Method and Description |
---|---|
CompiledUpdateSet |
ReplayableTableRecord.getCompiledUpdateSet() |
Modifier and Type | Method and Description |
---|---|
void |
ReplayableTableRecord.setCompiledUpdateSet(CompiledUpdateSet compiledUpdateSet) |
Constructor and Description |
---|
ReplayableTableRecord(ComplexEventChunk complexEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet)
For onUpdateError
|
ReplayableTableRecord(ComplexEventChunk complexEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor)
For onUpdateOrAddError
|
Copyright © 2021. All rights reserved.