S
- current state of the processorpublic abstract class StreamProcessor<S extends State> extends AbstractStreamProcessor<S>
attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder, streamEventClonerHolder
Constructor and Description |
---|
StreamProcessor() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
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 |
processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state)
The main processing method that will be called upon event arrival
|
constructStreamEventPopulater, getNextProcessor, getProcessingMode, getReturnAttributes, init, initProcessor, isStateful, process, process, setNextProcessor, setStreamEventCloner, setToLast
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
start, stop
protected void processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk, Processor nextProcessor, StreamEventCloner streamEventCloner, ComplexEventPopulater complexEventPopulater, S state)
AbstractStreamProcessor
processEventChunk
in class AbstractStreamProcessor<S extends State>
streamEventChunk
- the event chunk that need to be processednextProcessor
- the next processor to which the success events need to be passedstreamEventCloner
- helps to clone the incoming event for local storage or modificationcomplexEventPopulater
- helps to populate the events with the resultant attributesstate
- current state of the processorprotected abstract void process(ComplexEventChunk<StreamEvent> streamEventChunk, Processor nextProcessor, StreamEventCloner streamEventCloner, ComplexEventPopulater complexEventPopulater, S state)
streamEventChunk
- the event chunk that need to be processednextProcessor
- the next processor to which the success events need to be passedstreamEventCloner
- helps to clone the incoming event for local storage or modificationcomplexEventPopulater
- helps to populate the events with the resultant attributesstate
- current processor stateCopyright © 2019. All rights reserved.