public class GeoLocationApproximateStreamProcessor
extends org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
This method computed the average location of the locationRecorder using the collection iBeacons which the location recorder resides.
location.recorder - unique id of the object or item latitude - latitude value of the iBeacon longitude - longitude value of the iBeacon sensor.proximity - proximity which will be given by the iBeacon (eg: ENTER, RANGE, EXIT) sensor.uuid - unique id of the iBeacon sensor.weight - weight of the iBeacon which influence the averaging of the location (eg: approximate distance from the beacon timestamp - timestamp of the log which will be used to remove iBeacon from one's collection when there is no new log for 5 minutes
Accept Type(s) for geoLocationApproximate(location.recorder, latitude, longitude, sensor.proximity, sensor.uuid, sensor.weight, timestamp); location.recorder : STRING latitude : DOUBLE longitude : DOUBLE sensor.proximity : STRING sensor.uuid : STRING sensor.weight : DOUBLE timestamp : LONG
Return Type(s): DOUBLE, DOUBLE, BOOL
Constructor and Description |
---|
GeoLocationApproximateStreamProcessor() |
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 inputDefinition,
org.wso2.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
org.wso2.siddhi.core.util.config.ConfigReader configReader,
org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext) |
protected Object[] |
process(Object data) |
protected Object[] |
process(Object[] data) |
void |
restoreState(Map<String,Object> state) |
void |
start() |
void |
stop() |
init, processEventChunk
public GeoLocationApproximateStreamProcessor()
public void start()
public void stop()
protected Object[] process(Object[] data)
process
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 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 siddhiAppContext)
init
in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor
Copyright © 2017 WSO2. All rights reserved.