public class ExecutionPlanSubscriber
extends org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
Constructor and Description |
---|
ExecutionPlanSubscriber() |
Modifier and Type | Method and Description |
---|---|
Object[] |
currentState()
Used to collect the serializable state of the processing element, that need to be
persisted for the reconstructing the element to the same state on a different point of time
|
protected List<org.wso2.siddhi.query.api.definition.Attribute> |
init(org.wso2.siddhi.query.api.definition.AbstractDefinition abstractDefinition,
org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors,
org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
The init method of the StreamProcessor, this method will be called before other methods
|
protected Object[] |
process(Object data)
The process method of the StreamFunction, used when zero or one function parameter is provided
|
protected Object[] |
process(Object[] data)
The process method of the StreamFunction, used when more then one function parameters are provided
|
void |
restoreState(Object[] objects)
Used to restore serialized state of the processing element, for reconstructing
the element to the same state as if was on a previous point of time.
|
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.
|
init, processEventChunk
protected Object[] process(Object[] data)
process
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
data
- the data values for the function parametersprotected Object[] process(Object data)
process
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
data
- null if the function parameter count is zero or runtime data value of the function parameterprotected List<org.wso2.siddhi.query.api.definition.Attribute> init(org.wso2.siddhi.query.api.definition.AbstractDefinition abstractDefinition, org.wso2.siddhi.core.executor.ExpressionExecutor[] expressionExecutors, org.wso2.siddhi.core.config.ExecutionPlanContext executionPlanContext)
init
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
abstractDefinition
- the incoming stream definitionexpressionExecutors
- the executors of each function parametersexecutionPlanContext
- the context of the execution planpublic void start()
public void stop()
public Object[] currentState()
public void restoreState(Object[] objects)
objects
- the stateful objects of the element as an array on
the same order provided by currentState().Copyright © 2016 WSO2 Inc. All rights reserved.