public class GeocodeStreamFunctionProcessor
extends io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>
Constructor and Description |
---|
GeocodeStreamFunctionProcessor() |
Modifier and Type | Method and Description |
---|---|
List<io.siddhi.query.api.definition.Attribute> |
getReturnAttributes() |
protected io.siddhi.core.util.snapshot.state.StateFactory<io.siddhi.core.util.snapshot.state.State> |
init(io.siddhi.query.api.definition.AbstractDefinition abstractDefinition,
io.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
io.siddhi.core.util.config.ConfigReader configReader,
boolean outputExpectsExpiredEvents,
io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)
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 |
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
protected Object[] process(Object[] data)
process
in class io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>
data
- the data values for the function parametersprotected Object[] process(Object data)
process
in class io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>
data
- null if the function parameter count is zero or runtime data value of the function parameterprotected io.siddhi.core.util.snapshot.state.StateFactory<io.siddhi.core.util.snapshot.state.State> init(io.siddhi.query.api.definition.AbstractDefinition abstractDefinition, io.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, io.siddhi.core.util.config.ConfigReader configReader, boolean outputExpectsExpiredEvents, io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)
init
in class io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>
abstractDefinition
- the incoming stream definitionattributeExpressionExecutors
- the executors of each function parametersoutputExpectsExpiredEvents
- whether output can be expired eventsiddhiQueryContext
- siddhi query contextconfigReader
- this hold the stream Processor configuration reader.public void start()
public void stop()
public List<io.siddhi.query.api.definition.Attribute> getReturnAttributes()
getReturnAttributes
in class io.siddhi.core.query.processor.stream.AbstractStreamProcessor<io.siddhi.core.util.snapshot.state.State>
Copyright © 2019 WSO2. All rights reserved.