Modifier and Type | Class and Description |
---|---|
class |
SelectiveComplexEventPopulater
The populater class that populates StateEvents
|
Modifier and Type | Field and Description |
---|---|
protected ComplexEventPopulater |
AbstractStreamProcessor.complexEventPopulater |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
StreamProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state)
The main processing method that will be called upon event arrival
|
protected void |
LogStreamProcessor.process(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
State state) |
protected abstract void |
AbstractStreamProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state)
The main processing method that will be called upon event arrival
|
protected void |
StreamProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
Modifier and Type | Method and Description |
---|---|
protected void |
StreamFunctionProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
Modifier and Type | Method and Description |
---|---|
protected void |
BatchingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected void |
SlidingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected void |
HopingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected void |
GroupingWindowProcessor.processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state) |
protected void |
WindowWindowProcessor.processEventChunk(ComplexEventChunk streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
State state) |
Modifier and Type | Method and Description |
---|---|
void |
IncrementalAggregateCompileCondition.setComplexEventPopulater(ComplexEventPopulater complexEventPopulater) |
Copyright © 2019. All rights reserved.