Package | Description |
---|---|
io.siddhi.core.query | |
io.siddhi.core.query.processor.stream.window | |
io.siddhi.core.table.record | |
io.siddhi.core.util.collection.operator |
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 | Class and Description |
---|---|
class |
AbstractQueryableRecordTable.CompiledSelectionWithCache
class to hold both store compile selection and cache compile selection wrapped
|
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) |
CompiledSelection |
AbstractQueryableRecordTable.getCompiledSelectionForCaching() |
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) |
Constructor and Description |
---|
IncrementalAggregateCompileCondition(boolean isStoreQuery,
String aggregationName,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTableMap,
List<ExpressionExecutor> outputExpressionExecutors,
boolean isOptimisedLookup,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledSelection> withinTableCompiledSelection,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableLowerGranularityCompileCondition,
CompiledCondition onCompiledCondition,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
List<ExpressionExecutor> timestampFilterExecutors,
MetaStreamEvent aggregateMetaSteamEvent,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
MatchingMetaInfoHolder matchingHolderInfoForTableLookups,
List<VariableExpressionExecutor> variableExpExecutorsForTableLookups) |
Copyright © 2019. All rights reserved.