Constructor and Description |
---|
IncrementalAggregationProcessor(AggregationRuntime aggregationRuntime,
List<ExpressionExecutor> incomingExpressionExecutors,
MetaStreamEvent processedMetaStreamEvent,
LatencyTracker latencyTrackerInsert,
ThroughputTracker throughputTrackerInsert,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
Processor |
getNextProcessor()
Get next processor element in the processor chain.
|
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent
|
void |
process(List<ComplexEventChunk> complexEventChunks)
Process the handed StreamEvent
|
void |
setNextProcessor(Processor processor)
Set next processor element in processor chain
|
void |
setToLast(Processor processor)
Set as the last element of the processor chain
|
public IncrementalAggregationProcessor(AggregationRuntime aggregationRuntime, List<ExpressionExecutor> incomingExpressionExecutors, MetaStreamEvent processedMetaStreamEvent, LatencyTracker latencyTrackerInsert, ThroughputTracker throughputTrackerInsert, SiddhiAppContext siddhiAppContext)
public void process(ComplexEventChunk complexEventChunk)
Processor
public void process(List<ComplexEventChunk> complexEventChunks)
Processor
public Processor getNextProcessor()
Processor
getNextProcessor
in interface Processor
public void setNextProcessor(Processor processor)
Processor
setNextProcessor
in interface Processor
processor
- Processor to be set as next element of processor chainCopyright © 2021. All rights reserved.