public class Pol2CartStreamFunctionProcessor extends StreamFunctionProcessor
attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder, streamEventClonerHolder
Constructor and Description |
---|
Pol2CartStreamFunctionProcessor() |
Modifier and Type | Method and Description |
---|---|
List<io.siddhi.query.api.definition.Attribute> |
getReturnAttributes() |
protected StateFactory |
init(io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamFunction
|
protected Object[] |
process(Object data)
The process method of the StreamFunction, used when single function parameter is provided
|
protected Object[] |
process(Object[] data)
The process method of the StreamFunction, used when multiple function parameters are provided
|
void |
start()
This will be called only once and this can be used to acquire
required resources for the processing element.
|
void |
stop()
This will be called only once and this can be used to release
the acquired resources for processing.
|
getProcessingMode, init, processEventChunk
constructStreamEventPopulater, getNextProcessor, initProcessor, isStateful, process, process, setNextProcessor, setStreamEventCloner, setToLast
protected StateFactory init(io.siddhi.query.api.definition.AbstractDefinition inputDefinition, ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, boolean outputExpectsExpiredEvents, SiddhiQueryContext siddhiQueryContext)
init
in class StreamFunctionProcessor
inputDefinition
- the incoming stream definitionattributeExpressionExecutors
- the executors for the function parameterssiddhiQueryContext
- siddhi query contextconfigReader
- this hold the StreamFunctionProcessor
extensions configuration
reader.outputExpectsExpiredEvents
- is expired events sent as outputprotected Object[] process(Object[] data)
process
in class StreamFunctionProcessor
data
- the data values for the function parametersprotected Object[] process(Object data)
process
in class StreamFunctionProcessor
data
- the data value for the function parameterpublic void start()
ExternalReferencedHolder
public void stop()
ExternalReferencedHolder
public List<io.siddhi.query.api.definition.Attribute> getReturnAttributes()
getReturnAttributes
in class AbstractStreamProcessor
Copyright © 2021. All rights reserved.