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, MethodPollingExecStrategyMapPlain, MethodPollingExecStrategyOAPlain, MethodPollingExecStrategyPOJOPlain

public abstract class MethodPollingExecStrategyBase
extends java.lang.Object
implements PollExecStrategy

Viewable providing historical data from a database.

Field Summary

protected EventAdapterService	eventAdapterService
protected EventType	eventType
protected java.lang.Object	invocationTarget
protected net.sf.cglib.reflect.FastMethod	method
protected MethodPollingExecStrategyEnum	strategy
protected java.lang.String	variableName
protected VariableReader	variableReader
protected VariableService	variableService

Constructor Summary

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

Method Summary

protected boolean	checkNonNullArrayValue(java.lang.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 java.util.List<EventBean>	handleResult(java.lang.Object invocationResult)
java.util.List<EventBean>	poll(java.lang.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 java.lang.Object invocationTarget

strategy

protected final MethodPollingExecStrategyEnum strategy

variableReader

protected final VariableReader variableReader

variableName

protected final java.lang.String variableName

variableService

protected final VariableService variableService

Constructor Detail

MethodPollingExecStrategyBase

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

Method Detail

handleResult

protected abstract java.util.List<EventBean> handleResult(java.lang.Object invocationResult)

checkNonNullArrayValue

protected boolean checkNonNullArrayValue(java.lang.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 java.util.List<EventBean> poll(java.lang.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

Returns:

a list of events for the keys