org.wso2.extension.siddhi.execution.geo

Class GeoCoordinateStreamFunctionProcessor

java.lang.Object

io.siddhi.core.query.processor.stream.AbstractStreamProcessor<S>

io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>

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

All Implemented Interfaces:

io.siddhi.core.query.processor.Processor, io.siddhi.core.util.extension.holder.ExternalReferencedHolder

public class GeoCoordinateStreamFunctionProcessor
extends io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>

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

Field Summary

Fields inherited from class io.siddhi.core.query.processor.stream.AbstractStreamProcessor

attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder, streamEventClonerHolder

Constructor Summary

Constructors

Constructor and Description
GeoCoordinateStreamFunctionProcessor()

Method Summary

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)
protected Object[]	process(Object data)
protected Object[]	process(Object[] data)
void	start()
void	stop()

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

getProcessingMode, init, processEventChunk

Methods inherited from class io.siddhi.core.query.processor.stream.AbstractStreamProcessor

constructStreamEventPopulater, 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 io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>

process

protected Object[] process(Object data)

Specified by:

process in class io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>

init

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)

Specified by:

init in class io.siddhi.core.query.processor.stream.function.StreamFunctionProcessor<io.siddhi.core.util.snapshot.state.State>

start

public void start()

stop

public void stop()

getReturnAttributes

public List<io.siddhi.query.api.definition.Attribute> getReturnAttributes()

Specified by:

getReturnAttributes in class io.siddhi.core.query.processor.stream.AbstractStreamProcessor<io.siddhi.core.util.snapshot.state.State>