public class GeoClosestPointsStreamFunctionProcessor
extends org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
Constructor and Description |
---|
GeoClosestPointsStreamFunctionProcessor() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
currentState() |
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.util.config.ConfigReader configReader,
org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext) |
protected Object[] |
process(Object o) |
protected Object[] |
process(Object[] data) |
void |
restoreState(Map<String,Object> objects) |
void |
start() |
void |
stop() |
init, processEventChunk
public GeoClosestPointsStreamFunctionProcessor()
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.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
init
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
protected Object[] process(Object[] data)
process
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
protected Object[] process(Object o)
process
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
public void start()
public void stop()
Copyright © 2017 WSO2. All rights reserved.