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) |
IncrementalAggregationProcessor(AggregationRuntime aggregationRuntime,
List<ExpressionExecutor> incomingExpressionExecutors,
MetaStreamEvent processedMetaStreamEvent,
LatencyTracker latencyTrackerInsert,
ThroughputTracker throughputTrackerInsert,
SiddhiAppContext siddhiAppContext) |
IncrementalDataAggregator(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
io.siddhi.query.api.aggregation.TimePeriod.Duration durationToAggregate,
long oldestEventTimestamp,
List<ExpressionExecutor> baseExecutorsForFind,
ExpressionExecutor shouldUpdateTimestamp,
boolean groupBy,
MetaStreamEvent metaStreamEvent) |
IncrementalExecutor(String aggregatorName,
io.siddhi.query.api.aggregation.TimePeriod.Duration duration,
List<ExpressionExecutor> processExpressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
boolean isRoot,
Table table,
IncrementalExecutor child,
SiddhiQueryContext siddhiQueryContext,
MetaStreamEvent metaStreamEvent) |
IncrementalExecutorsInitialiser(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
boolean isDistributed,
String shardId,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
OutOfOrderEventsDataAggregator(List<ExpressionExecutor> baseExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
MetaStreamEvent metaStreamEvent) |
Modifier and Type | Method and Description |
---|---|
MetaStreamEvent |
MetaStateEvent.getMetaStreamEvent(int position) |
MetaStreamEvent[] |
MetaStateEvent.getMetaStreamEvents() |
Modifier and Type | Method and Description |
---|---|
void |
MetaStateEvent.addEvent(MetaStreamEvent metaStreamEvent) |
Constructor and Description |
---|
MetaStateEvent(MetaStreamEvent[] metaStreamEvents) |
Modifier and Type | Method and Description |
---|---|
MetaStreamEvent |
MetaStreamEvent.clone() |
Constructor and Description |
---|
StreamEventCloner(MetaStreamEvent metaStreamEvent,
StreamEventFactory eventFactory) |
StreamEventFactory(MetaStreamEvent metaStreamEvent)
Initialization of the factory using MetaStreamEvent
|
Modifier and Type | Method and Description |
---|---|
static StreamEventConverter |
StreamEventConverterFactory.constructEventConverter(MetaStreamEvent metaStreamEvent) |
Constructor and Description |
---|
ConversionStreamEventChunk(MetaStreamEvent metaStreamEvent,
StreamEventFactory streamEventFactory) |
Modifier and Type | Method and Description |
---|---|
static SelectiveComplexEventPopulater |
StreamEventPopulaterFactory.constructEventPopulator(MetaStreamEvent metaStreamEvent,
int streamEventChainIndex,
List<io.siddhi.query.api.definition.Attribute> attributes)
Constructs StreamEventPopulater according to MetaStateEvent and to be mapped attributes
|
Constructor and Description |
---|
PartitionStreamReceiver(SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
List<PartitionExecutor> partitionExecutors,
PartitionRuntime partitionRuntime) |
Modifier and Type | Method and Description |
---|---|
void |
OnDemandQueryRuntime.setMetaStreamEvent(MetaStreamEvent metaStreamEvent) |
Constructor and Description |
---|
DeleteOnDemandQueryRuntime(String queryName,
MetaStreamEvent metaStreamEvent) |
FindOnDemandQueryRuntime(AggregationRuntime aggregation,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
FindOnDemandQueryRuntime(Table table,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
FindOnDemandQueryRuntime(Window window,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
InsertOnDemandQueryRuntime(String queryName,
MetaStreamEvent metaStreamEvent) |
UpdateOnDemandQueryRuntime(String queryName,
MetaStreamEvent metaStreamEvent) |
UpdateOrInsertOnDemandQueryRuntime(String queryName,
MetaStreamEvent metaStreamEvent) |
Modifier and Type | Method and Description |
---|---|
void |
MultiProcessStreamReceiver.setMetaStreamEvent(MetaStreamEvent metaStreamEvent) |
void |
ProcessStreamReceiver.setMetaStreamEvent(MetaStreamEvent metaStreamEvent) |
Modifier and Type | Field and Description |
---|---|
protected MetaStreamEvent |
AbstractStreamProcessor.metaStreamEvent |
Modifier and Type | Method and Description |
---|---|
void |
AbstractStreamProcessor.constructStreamEventPopulater(MetaStreamEvent metaStreamEvent,
int streamEventChainIndex) |
protected abstract StateFactory<S> |
AbstractStreamProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
protected StateFactory |
LogStreamProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamFunction
|
void |
AbstractStreamProcessor.initProcessor(MetaStreamEvent metaStreamEvent,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
boolean groupBy,
io.siddhi.query.api.SiddhiElement siddhiElement,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<S> |
StreamFunctionProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
Modifier and Type | Method and Description |
---|---|
void |
HopingWindowProcessor.constructStreamEventPopulater(MetaStreamEvent metaStreamEvent,
int streamEventChainIndex) |
void |
GroupingWindowProcessor.constructStreamEventPopulater(MetaStreamEvent metaStreamEvent,
int streamEventChainIndex) |
protected StateFactory |
WindowWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
BatchingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
SlidingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
HopingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
GroupingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
IncrementalAggregateCompileCondition(boolean isOnDemandQuery,
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) |
Modifier and Type | Method and Description |
---|---|
static StreamEvent |
AggregationParser.createRestEvent(MetaStreamEvent metaStreamEvent,
StreamEvent streamEvent) |
Copyright © 2019. All rights reserved.