Package | Description |
---|---|
io.siddhi.core.query.processor.stream.window |
Modifier and Type | Field and Description |
---|---|
protected GroupingWindowProcessor.GroupingKeyPopulator |
GroupingWindowProcessor.groupingKeyPopulator |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
GroupingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
GroupingWindowProcessor.GroupingKeyPopulator groupingKeyPopulater,
S state)
The main processing method that will be called upon event arrival
|
protected void |
SessionWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
GroupingWindowProcessor.GroupingKeyPopulator groupingKeyPopulater,
io.siddhi.core.query.processor.stream.window.SessionWindowProcessor.WindowState state) |
Copyright © 2021. All rights reserved.