Modifier and Type | Method and Description |
---|---|
CompiledCondition |
AggregationRuntime.compileExpression(io.siddhi.query.api.expression.Expression expression,
io.siddhi.query.api.aggregation.Within within,
io.siddhi.query.api.expression.Expression per,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
AggregationRuntime.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
InConditionExpressionExecutor(Table table,
CompiledCondition compiledCondition,
int streamEventSize,
boolean isMatchingEventAStateEvent,
int matchingStreamIndex) |
Constructor and Description |
---|
FindStoreQueryRuntime(AggregationRuntime aggregation,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
FindStoreQueryRuntime(Table table,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
FindStoreQueryRuntime(Window window,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
SelectStoreQueryRuntime(QueryableProcessor queryableProcessor,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributeList,
String queryName) |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
JoinProcessor.getCompiledCondition() |
Modifier and Type | Method and Description |
---|---|
void |
JoinProcessor.setCompiledCondition(CompiledCondition compiledCondition) |
Constructor and Description |
---|
DeleteTableCallback(Table table,
CompiledCondition compiledCondition,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
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 |
---|---|
CompiledCondition |
BatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.BatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
ExternalTimeBatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.ExternalTimeBatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
ExternalTimeWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.ExternalTimeWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
FrequentWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.FrequentWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
CompiledCondition |
LengthBatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.LengthBatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
LengthWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.LengthWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
LossyFrequentWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.LossyFrequentWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
CompiledCondition |
SessionWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.SessionWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
BatchingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
GroupingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
TableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
FindableProcessor.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.
|
CompiledCondition |
WindowWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
SlidingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
AggregateWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
SortWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.SortWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
abstract CompiledCondition |
BatchingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
S state,
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.
|
abstract CompiledCondition |
GroupingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
S state,
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.
|
abstract CompiledCondition |
SlidingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
S state,
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.
|
CompiledCondition |
TimeBatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeBatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
TimeLengthWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeLengthWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
TimeWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
DelayWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
BatchingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
StreamEvent |
GroupingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
StreamEvent |
TableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
StreamEvent |
FindableProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
StreamEvent |
WindowWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
StreamEvent |
SlidingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
StreamEvent |
AggregateWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
StreamEvent |
BatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.BatchWindowProcessor.WindowState state) |
StreamEvent |
ExternalTimeBatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.ExternalTimeBatchWindowProcessor.WindowState state) |
StreamEvent |
ExternalTimeWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.ExternalTimeWindowProcessor.WindowState state) |
StreamEvent |
FrequentWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.FrequentWindowProcessor.WindowState state)
Deprecated.
|
StreamEvent |
LengthBatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LengthBatchWindowProcessor.WindowState state) |
StreamEvent |
LengthWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LengthWindowProcessor.WindowState state) |
StreamEvent |
LossyFrequentWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.LossyFrequentWindowProcessor.WindowState state)
Deprecated.
|
abstract StreamEvent |
BatchingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
S state)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
abstract StreamEvent |
GroupingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
S state)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
abstract StreamEvent |
SlidingFindableWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
S state)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
StreamEvent |
SessionWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.SessionWindowProcessor.WindowState state) |
StreamEvent |
SortWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.SortWindowProcessor.WindowState state) |
StreamEvent |
TimeBatchWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeBatchWindowProcessor.WindowState state) |
StreamEvent |
TimeLengthWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeLengthWindowProcessor.WindowState state) |
StreamEvent |
TimeWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state) |
StreamEvent |
DelayWindowProcessor.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
StreamEventCloner streamEventCloner,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state) |
StreamEvent |
QueryableProcessor.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
StreamEvent |
QueryableProcessor.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic and
return them based on the defined selection.
|
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
InMemoryTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
Table.contains(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
boolean |
InMemoryTable.contains(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
boolean |
Table.containsEvent(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
protected abstract void |
Table.delete(ComplexEventChunk<StateEvent> deletingEventChunk,
CompiledCondition compiledCondition) |
void |
InMemoryTable.delete(ComplexEventChunk<StateEvent> deletingEventChunk,
CompiledCondition compiledCondition) |
void |
Table.deleteEvents(ComplexEventChunk<StateEvent> deletingEventChunk,
CompiledCondition compiledCondition,
int noOfEvents) |
protected abstract StreamEvent |
Table.find(CompiledCondition compiledCondition,
StateEvent matchingEvent) |
StreamEvent |
InMemoryTable.find(CompiledCondition compiledCondition,
StateEvent matchingEvent) |
StreamEvent |
Table.find(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
protected abstract void |
Table.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
InMemoryTable.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
Table.updateEvents(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int noOfEvents) |
protected abstract void |
Table.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
InMemoryTable.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
Table.updateOrAddEvents(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor,
int noOfEvents) |
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractRecordTable.RecordStoreCompiledCondition
Compiled condition of the
AbstractRecordTable |
Modifier and Type | Field and Description |
---|---|
protected CompiledCondition |
AbstractRecordTable.RecordStoreCompiledCondition.compiledCondition |
Modifier and Type | Method and Description |
---|---|
protected abstract CompiledCondition |
AbstractRecordTable.compileCondition(ExpressionBuilder expressionBuilder)
Compile the matching expression
|
CompiledCondition |
AbstractRecordTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
boolean |
RecordTableHandler.contains(long timestamp,
Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition) |
abstract boolean |
RecordTableHandler.contains(long timestamp,
Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
protected abstract boolean |
AbstractRecordTable.contains(Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition)
Check if matching record exist
|
boolean |
RecordTableHandlerCallback.contains(Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition) |
boolean |
AbstractRecordTable.contains(StateEvent matchingEvent,
CompiledCondition compiledCondition) |
void |
AbstractRecordTable.delete(ComplexEventChunk<StateEvent> deletingEventChunk,
CompiledCondition compiledCondition) |
protected abstract void |
AbstractRecordTable.delete(List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition)
Delete all matching records
|
void |
RecordTableHandlerCallback.delete(List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition) |
void |
RecordTableHandler.delete(long timestamp,
List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition) |
abstract void |
RecordTableHandler.delete(long timestamp,
List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
StreamEvent |
AbstractRecordTable.find(CompiledCondition compiledCondition,
StateEvent matchingEvent) |
Iterator<Object[]> |
RecordTableHandler.find(long timestamp,
Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition) |
abstract Iterator<Object[]> |
RecordTableHandler.find(long timestamp,
Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
protected abstract RecordIterator<Object[]> |
AbstractRecordTable.find(Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition)
Find records matching the compiled condition
|
RecordIterator<Object[]> |
RecordTableHandlerCallback.find(Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition) |
Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
abstract Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
abstract Iterator<Object[]> |
RecordTableHandler.query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
RecordTableHandlerCallback recordTableHandlerCallback,
S state)
Deprecated.
|
Iterator<Object[]> |
RecordTableHandlerCallback.query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
protected abstract RecordIterator<Object[]> |
AbstractQueryableRecordTable.query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes)
Query records matching the compiled condition and selection
|
Iterator<Object[]> |
RecordTableHandlerCallback.query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
StreamEvent |
AbstractQueryableRecordTable.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection) |
StreamEvent |
AbstractQueryableRecordTable.query(StateEvent matchingEvent,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
protected abstract void |
AbstractRecordTable.update(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps)
Update all matching records
|
void |
RecordTableHandlerCallback.update(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps) |
void |
AbstractRecordTable.update(ComplexEventChunk<StateEvent> updatingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet) |
void |
RecordTableHandler.update(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps) |
abstract void |
RecordTableHandler.update(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
protected abstract void |
AbstractRecordTable.updateOrAdd(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords)
Try updating the records if they exist else add the records
|
void |
RecordTableHandlerCallback.updateOrAdd(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
void |
AbstractRecordTable.updateOrAdd(ComplexEventChunk<StateEvent> updateOrAddingEventChunk,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
AddingStreamEventExtractor addingStreamEventExtractor) |
void |
RecordTableHandler.updateOrAdd(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
abstract void |
RecordTableHandler.updateOrAdd(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords,
RecordTableHandlerCallback recordTableHandlerCallback) |
Modifier and Type | Interface and Description |
---|---|
interface |
Operator
Interface for Operators related to collection of events.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectionOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
EventChunkOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
IncrementalAggregateCompileCondition
Defines the logic to find a matching event from an incremental aggregator (retrieval from incremental aggregator),
based on the logical conditions defined herewith.
|
class |
IndexOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
MapOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
OverwriteTableIndexOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
SnapshotableEventQueueOperator
Operator which is related to non-indexed In-memory table operations.
|
Constructor and Description |
---|
IncrementalAggregateCompileCondition(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
CompiledCondition onCompiledCondition,
MetaStreamEvent tableMetaStreamEvent,
MetaStreamEvent aggregateMetaSteamEvent,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
boolean isProcessingOnExternalTime) |
Constructor and Description |
---|
IncrementalAggregateCompileCondition(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
CompiledCondition onCompiledCondition,
MetaStreamEvent tableMetaStreamEvent,
MetaStreamEvent aggregateMetaSteamEvent,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
boolean isProcessingOnExternalTime) |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
Window.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.
|
Modifier and Type | Method and Description |
---|---|
StreamEvent |
Window.find(StateEvent matchingEvent,
CompiledCondition compiledCondition)
To find events from the processor event pool, that the matches the matchingEvent based on finder logic.
|
Copyright © 2019. All rights reserved.