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,
List<io.siddhi.query.api.expression.Variable> queryGroupByList,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
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 |
EmptyWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.EmptyWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
ExpressionBatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.ExpressionBatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
ExpressionWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.ExpressionWindowProcessor.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 |
SlidingFindableWindowProcessor.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 |
WindowWindowProcessor.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 |
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 |
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 |
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.
|
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.
|
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) |
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.
|
CompiledSelection |
TableWindowProcessor.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 |
---|---|
CompiledCondition |
InMemoryTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
CacheTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext,
boolean updateCachePolicyAttribute) |
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.
|
CacheTable.CacheCompiledConditionWithRouteToCache |
CacheTable.generateCacheCompileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder storeMatchingMetaInfoHolder,
SiddhiQueryContext siddhiQueryContext,
List<VariableExpressionExecutor> storeVariableExpressionExecutors) |
Modifier and Type | Field and Description |
---|---|
protected MatchingMetaInfoHolder |
AbstractQueryableRecordTable.matchingMetaInfoHolderForTestOnDemandQuery |
Modifier and Type | Method and Description |
---|---|
MatchingMetaInfoHolder |
ExpressionBuilder.getMatchingMetaInfoHolder() |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
AbstractQueryableRecordTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
AbstractRecordTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
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) |
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) |
Constructor and Description |
---|
UpdateOrInsertReducer(ExpressionExecutor inMemoryCompiledCondition,
MatchingMetaInfoHolder matchingMetaInfoHolder) |
Modifier and Type | Method and Description |
---|---|
MatchingMetaInfoHolder |
IncrementalAggregateCompileCondition.getAlteredMatchingMetaInfoHolder() |
Constructor and Description |
---|
IncrementalAggregateCompileCondition(boolean isOnDemandQuery,
String aggregationName,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> activeIncrementalDurations,
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) |
Modifier and Type | Method and Description |
---|---|
static MatchingMetaInfoHolder |
MatcherParser.constructMatchingMetaStateHolder(MetaComplexEvent matchingMetaComplexEvent,
int defaultStreamEventIndex,
io.siddhi.query.api.definition.AbstractDefinition candsidateDefinition,
int currentState) |
static MatchingMetaInfoHolder |
OnDemandQueryParser.generateMatchingMetaInfoHolderForCacheTable(io.siddhi.query.api.definition.TableDefinition tableDefinition) |
Modifier and Type | Method and Description |
---|---|
static CollectionExecutor |
CollectionExpressionParser.buildCollectionExecutor(CollectionExpression collectionExpression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
boolean isFirst,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext,
boolean isCache,
CacheTable cacheTable) |
static List<io.siddhi.query.api.definition.Attribute> |
OnDemandQueryParser.buildExpectedOutputAttributes(io.siddhi.query.api.execution.query.OnDemandQuery onDemandQuery,
Map<String,Table> tableMap,
int metaPosition,
MatchingMetaInfoHolder metaStreamInfoHolder,
SiddhiQueryContext siddhiQueryContext) |
static Operator |
OperatorParser.constructOperator(Object storeEvents,
io.siddhi.query.api.expression.Expression expression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
static Operator |
OperatorParser.constructOperatorForCache(Object storeEvents,
io.siddhi.query.api.expression.Expression expression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext,
boolean updateCachePolicyAttribute,
CacheTable cacheTable) |
static CollectionExpression |
CollectionExpressionParser.parseCollectionExpression(io.siddhi.query.api.expression.Expression expression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
IndexedEventHolder indexedEventHolder)
Parse the given expression and create the appropriate Executor by recursively traversing the expression.
|
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.
|
Copyright © 2021. All rights reserved.