com.espertech.esper.epl.core

Class MethodPollingExecStrategyBase

java.lang.Object

com.espertech.esper.epl.core.MethodPollingExecStrategyBase

All Implemented Interfaces:

PollExecStrategy

Direct Known Subclasses:

MethodPollingExecStrategyBaseArray, MethodPollingExecStrategyBaseCollection, MethodPollingExecStrategyBaseIterator, MethodPollingExecStrategyEventBeans, MethodPollingExecStrategyMapPlain, MethodPollingExecStrategyOAPlain, MethodPollingExecStrategyPOJOPlain

public abstract class MethodPollingExecStrategyBase
extends Object
implements PollExecStrategy

Viewable providing historical data from a database.

Field Summary

Fields

Modifier and Type	Field and Description
protected EventAdapterService	eventAdapterService
protected EventType	eventType
protected Object	invocationTarget
protected net.sf.cglib.reflect.FastMethod	method
protected MethodPollingExecStrategyEnum	strategy
protected String	variableName
protected VariableReader	variableReader
protected VariableService	variableService

Constructor Summary

Constructors

Constructor and Description
MethodPollingExecStrategyBase(EventAdapterService eventAdapterService, net.sf.cglib.reflect.FastMethod method, EventType eventType, Object invocationTarget, MethodPollingExecStrategyEnum strategy, VariableReader variableReader, String variableName, VariableService variableService)

Method Summary

Modifier and Type	Method and Description
protected boolean	checkNonNullArrayValue(Object value)
void	destroy() Indicate we are no going to use this object again.
void	done() Indicate we are done polling and can release resources.
protected abstract List<EventBean>	handleResult(Object invocationResult)
List<EventBean>	poll(Object[] lookupValues, ExprEvaluatorContext exprEvaluatorContext) Poll events using the keys provided.
void	start() Start the poll, called before any poll operation.

Methods inherited from class java.lang.Object

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

Field Detail

eventAdapterService

protected final EventAdapterService eventAdapterService

method

protected final net.sf.cglib.reflect.FastMethod method

eventType

protected final EventType eventType

invocationTarget

protected final Object invocationTarget

strategy

protected final MethodPollingExecStrategyEnum strategy

variableReader

protected final VariableReader variableReader

variableName

protected final String variableName

variableService

protected final VariableService variableService

Constructor Detail

MethodPollingExecStrategyBase

public MethodPollingExecStrategyBase(EventAdapterService eventAdapterService,
                                     net.sf.cglib.reflect.FastMethod method,
                                     EventType eventType,
                                     Object invocationTarget,
                                     MethodPollingExecStrategyEnum strategy,
                                     VariableReader variableReader,
                                     String variableName,
                                     VariableService variableService)

Method Detail

handleResult

protected abstract List<EventBean> handleResult(Object invocationResult)

checkNonNullArrayValue

protected boolean checkNonNullArrayValue(Object value)

start

public void start()

Description copied from interface: PollExecStrategy

Start the poll, called before any poll operation.

Specified by:

start in interface PollExecStrategy

done

public void done()

Description copied from interface: PollExecStrategy

Indicate we are done polling and can release resources.

Specified by:

done in interface PollExecStrategy

destroy

public void destroy()

Description copied from interface: PollExecStrategy

Indicate we are no going to use this object again.

Specified by:

destroy in interface PollExecStrategy

poll

public List<EventBean> poll(Object[] lookupValues,
                            ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: PollExecStrategy

Poll events using the keys provided.

Specified by:

poll in interface PollExecStrategy

Parameters:

lookupValues - is keys for exeuting a query or such

exprEvaluatorContext - context

Returns:

a list of events for the keys