org.wso2.extension.siddhi.execution.geo

Class GeoCoordinateStreamFunctionProcessor

java.lang.Object

org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor

org.wso2.extension.siddhi.execution.geo.GeoCoordinateStreamFunctionProcessor

All Implemented Interfaces:

org.wso2.siddhi.core.query.processor.Processor, org.wso2.siddhi.core.util.extension.holder.EternalReferencedHolder, org.wso2.siddhi.core.util.snapshot.Snapshotable

public class GeoCoordinateStreamFunctionProcessor
extends org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor

This class is to get longitude and latitude value of login location based on ip address.

Field Summary

Fields inherited from class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor

outputExpectsExpiredEvents

Fields inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

additionalAttributes, attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, elementId, inputDefinition, nextProcessor, queryName, siddhiAppContext, streamEventCloner, streamEventClonerHolder

Constructor Summary

Constructors

Constructor and Description
GeoCoordinateStreamFunctionProcessor()

Method Summary

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()

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor

init, processEventChunk

Methods inherited from class org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor

cloneProcessor, constructStreamEventPopulater, getElementId, getNextProcessor, initProcessor, process, setNextProcessor, setStreamEventCloner, setToLast

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GeoCoordinateStreamFunctionProcessor

public GeoCoordinateStreamFunctionProcessor()

Method Detail

process

protected Object[] process(Object[] data)

Specified by:

process in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor

process

protected Object[] process(Object data)

Specified by:

process in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor

init

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)

Specified by:

init in class org.wso2.siddhi.core.query.processor.stream.function.StreamFunctionProcessor

start

public void start()

stop

public void stop()

currentState

public Map<String,Object> currentState()

restoreState

public void restoreState(Map<String,Object> state)