Package | Description |
---|---|
io.siddhi.core.query | |
io.siddhi.core.query.processor.stream.window | |
io.siddhi.core.table.record |
Constructor and Description |
---|
SelectStoreQueryRuntime(QueryableProcessor queryableProcessor,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributeList,
String queryName) |
Modifier and Type | Method and Description |
---|---|
CompiledSelection |
QueryableProcessor.compileSelection(io.siddhi.query.api.execution.query.selection.Selector selector,
List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributes,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext)
To construct a selection having the capability of transforming events based on given selection logic.
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
protected abstract CompiledSelection |
AbstractQueryableRecordTable.compileSelection(List<AbstractQueryableRecordTable.SelectAttributeBuilder> selectAttributeBuilders,
List<ExpressionBuilder> groupByExpressionBuilder,
ExpressionBuilder havingExpressionBuilder,
List<AbstractQueryableRecordTable.OrderByAttributeBuilder> orderByAttributeBuilders,
Long limit,
Long offset)
Compile the query selection
|
CompiledSelection |
AbstractQueryableRecordTable.compileSelection(io.siddhi.query.api.execution.query.selection.Selector selector,
List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributes,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
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.
|
Iterator<Object[]> |
RecordTableHandlerCallback.query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
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
|
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) |
Copyright © 2019. All rights reserved.