Constructor and Description |
---|
AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
SingleStreamRuntime singleStreamRuntime,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
MetaStreamEvent tableMetaStreamEvent,
List<ExpressionExecutor> outputExpressionExecutors,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind,
RecreateInMemoryData recreateInMemoryData,
boolean processingOnExternalTime,
List<GroupByKeyGenerator> groupByKeyGeneratorList,
IncrementalDataPurging incrementalDataPurging,
String shardId,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions,
ExpressionExecutor shouldUpdateTimestamp,
List<List<ExpressionExecutor>> aggregateProcessExpressionExecutorsListForFind) |
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,
MetaStreamEvent metaStreamEvent,
ExpressionExecutor shouldUpdateTimestamp,
boolean groupBy) |
IncrementalExecutor(io.siddhi.query.api.aggregation.TimePeriod.Duration duration,
List<ExpressionExecutor> processExpressionExecutors,
GroupByKeyGenerator groupByKeyGenerator,
MetaStreamEvent metaStreamEvent,
IncrementalExecutor child,
boolean isRoot,
Table table,
SiddhiQueryContext siddhiQueryContext,
String aggregatorName,
ExpressionExecutor shouldUpdateTimestamp) |
IncrementalExternalTimestampDataAggregator(List<ExpressionExecutor> baseExecutors,
GroupByKeyGenerator groupByKeyGenerator,
MetaStreamEvent metaStreamEvent,
SiddhiQueryContext siddhiQueryContext,
ExpressionExecutor shouldUpdateTimestamp) |
RecreateInMemoryData(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,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
String shardId,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions) |
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) |
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) |
Constructor and Description |
---|
DeleteStoreQueryRuntime(String queryName,
MetaStreamEvent metaStreamEvent) |
FindStoreQueryRuntime(AggregationRuntime aggregation,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
FindStoreQueryRuntime(Table table,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
FindStoreQueryRuntime(Window window,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
InsertStoreQueryRuntime(String queryName,
MetaStreamEvent metaStreamEvent) |
UpdateOrInsertStoreQueryRuntime(String queryName,
MetaStreamEvent metaStreamEvent) |
UpdateStoreQueryRuntime(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 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
|
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
|
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 |
GroupingWindowProcessor.constructStreamEventPopulater(MetaStreamEvent metaStreamEvent,
int streamEventChainIndex) |
void |
HopingWindowProcessor.constructStreamEventPopulater(MetaStreamEvent metaStreamEvent,
int streamEventChainIndex) |
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) |
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> |
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 |
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) |
Constructor and Description |
---|
IncrementalAggregateCompileCondition(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
CompiledCondition onCompiledCondition,
MetaStreamEvent tableMetaStreamEvent,
MetaStreamEvent aggregateMetaSteamEvent,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
boolean isProcessingOnExternalTime) |
Modifier and Type | Method and Description |
---|---|
static StreamEvent |
AggregationParser.createRestEvent(MetaStreamEvent metaStreamEvent,
StreamEvent streamEvent) |
Copyright © 2019. All rights reserved.