Constructor and Description |
---|
PersistedAggregationResultsProcessor(io.siddhi.query.api.aggregation.TimePeriod.Duration duration) |
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 PersistedAggregationResultsProcessor(io.siddhi.query.api.aggregation.TimePeriod.Duration duration)
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.