S
- current state of the processorpublic abstract class StreamFunctionProcessor<S extends State> extends AbstractStreamProcessor<S>
attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder, streamEventClonerHolder
Constructor and Description |
---|
StreamFunctionProcessor() |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
getProcessingMode()
Defines the behaviour of the processing, will be called after the init
|
protected abstract StateFactory<S> |
init(io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
protected StateFactory<S> |
init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
protected abstract Object[] |
process(Object data)
The process method of the StreamFunction, used when zero or one function parameter is provided
|
protected abstract Object[] |
process(Object[] data)
The process method of the StreamFunction, used when more then one function parameters are provided
|
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, getReturnAttributes, initProcessor, 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 processorpublic ProcessingMode getProcessingMode()
AbstractStreamProcessor
getProcessingMode
in class AbstractStreamProcessor<S extends State>
protected abstract Object[] process(Object[] data)
data
- the data values for the function parametersprotected abstract Object[] process(Object data)
data
- null if the function parameter count is zero or runtime data value of the function parameterprotected StateFactory<S> init(MetaStreamEvent metaStreamEvent, io.siddhi.query.api.definition.AbstractDefinition inputDefinition, ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, StreamEventClonerHolder streamEventClonerHolder, boolean outputExpectsExpiredEvents, boolean findToBeExecuted, SiddhiQueryContext siddhiQueryContext)
init
in class AbstractStreamProcessor<S extends State>
metaStreamEvent
- the stream event metainputDefinition
- the incoming stream definitionattributeExpressionExecutors
- the executors of each function parametersconfigReader
- this hold the StreamFunctionProcessor
extensions configurationstreamEventClonerHolder
- stream event cloner HolderoutputExpectsExpiredEvents
- is expired events sent as outputfindToBeExecuted
- find operation will be performedsiddhiQueryContext
- siddhi query contextprotected abstract StateFactory<S> init(io.siddhi.query.api.definition.AbstractDefinition inputDefinition, ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, boolean outputExpectsExpiredEvents, SiddhiQueryContext siddhiQueryContext)
inputDefinition
- the incoming stream definitionattributeExpressionExecutors
- the executors of each function parametersconfigReader
- this hold the StreamFunctionProcessor
extensions configuration
reader.outputExpectsExpiredEvents
- is expired events sent as outputsiddhiQueryContext
- the context of the siddhi queryCopyright © 2019. All rights reserved.