public class ReverseGeocodeStreamFunctionProcessor
extends org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
outputExpectsExpiredEvents
additionalAttributes, attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, elementId, inputDefinition, nextProcessor, queryName, siddhiAppContext, streamEventCloner, streamEventClonerHolder
Constructor and Description |
---|
ReverseGeocodeStreamFunctionProcessor() |
Modifier and Type | Method and Description |
---|---|
Map<String,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 inputDefinition,
org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
org.wso2.siddhi.core.util.config.ConfigReader configReader,
org.wso2.siddhi.core.config.SiddhiAppContext 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(Map<String,Object> state)
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
public ReverseGeocodeStreamFunctionProcessor()
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 inputDefinition, org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext executionPlanContext)
init
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
inputDefinition
- the incoming stream definitionattributeExpressionExecutors
- the executors of each function parametersexecutionPlanContext
- the context of the execution planpublic void start()
public void stop()
public Map<String,Object> currentState()
public void restoreState(Map<String,Object> state)
state
- the stateful objects of the element as an array on
the same order provided by currentState().Copyright © 2018 WSO2. All rights reserved.