Modifier and Type | Method and Description |
---|---|
SingleStreamRuntime |
AggregationRuntime.getSingleStreamRuntime() |
Constructor and Description |
---|
AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
List<ExpressionExecutor> outputExpressionExecutors,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
ExpressionExecutor shouldUpdateTimestamp,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
boolean isOptimisedLookup,
List<io.siddhi.query.api.execution.query.selection.OutputAttribute> defaultSelectorList,
List<String> groupByVariablesList,
boolean isLatestEventColAdded,
int baseAggregatorBeginIndex,
List<io.siddhi.query.api.expression.Expression> finalBaseExpressionList,
IncrementalDataPurger incrementalDataPurger,
IncrementalExecutorsInitialiser incrementalExecutorInitialiser,
SingleStreamRuntime singleStreamRuntime,
MetaStreamEvent tableMetaStreamEvent,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind) |
Modifier and Type | Method and Description |
---|---|
List<SingleStreamRuntime> |
StreamRuntime.getSingleStreamRuntimes() |
Modifier and Type | Method and Description |
---|---|
List<SingleStreamRuntime> |
JoinStreamRuntime.getSingleStreamRuntimes() |
Modifier and Type | Method and Description |
---|---|
void |
JoinStreamRuntime.addRuntime(SingleStreamRuntime singleStreamRuntime) |
Modifier and Type | Method and Description |
---|---|
List<SingleStreamRuntime> |
SingleStreamRuntime.getSingleStreamRuntimes() |
Modifier and Type | Method and Description |
---|---|
List<SingleStreamRuntime> |
StateStreamRuntime.getSingleStreamRuntimes() |
Modifier and Type | Field and Description |
---|---|
protected List<SingleStreamRuntime> |
StreamInnerStateRuntime.singleStreamRuntimeList |
Modifier and Type | Method and Description |
---|---|
List<SingleStreamRuntime> |
InnerStateRuntime.getSingleStreamRuntimeList() |
List<SingleStreamRuntime> |
StreamInnerStateRuntime.getSingleStreamRuntimeList() |
Modifier and Type | Method and Description |
---|---|
void |
InnerStateRuntime.addStreamRuntime(SingleStreamRuntime singleStreamRuntime) |
void |
StreamInnerStateRuntime.addStreamRuntime(SingleStreamRuntime singleStreamRuntime) |
Modifier and Type | Method and Description |
---|---|
static SingleStreamRuntime |
SingleInputStreamParser.parseInputStream(io.siddhi.query.api.execution.query.input.stream.SingleInputStream inputStream,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
Map<String,Table> tableMap,
MetaComplexEvent metaComplexEvent,
ProcessStreamReceiver processStreamReceiver,
boolean supportsBatchProcessing,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
boolean multiValue,
SiddhiQueryContext siddhiQueryContext)
Parse single InputStream and return SingleStreamRuntime
|
Copyright © 2019. All rights reserved.