com.espertech.esper.common.internal.epl.historical.common

Class HistoricalEventViewableFactoryBase

java.lang.Object

com.espertech.esper.common.internal.epl.historical.common.HistoricalEventViewableFactoryBase

All Implemented Interfaces:

StatementReadyCallback, HistoricalEventViewableFactory

Direct Known Subclasses:

HistoricalEventViewableDatabaseFactory, HistoricalEventViewableMethodFactory

public abstract class HistoricalEventViewableFactoryBase
extends Object
implements HistoricalEventViewableFactory

Implements a poller viewable that uses a polling strategy, a cache and some input parameters extracted from event streams to perform the polling.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExprEvaluator	evaluator
protected EventType	eventType
protected boolean	hasRequiredStreams
protected HistoricalEventViewableLookupValueToMultiKey	lookupValueToMultiKey
protected int	scheduleCallbackId
protected int	streamNumber

Constructor Summary

Constructors

Constructor and Description
HistoricalEventViewableFactoryBase()

Method Summary

Modifier and Type	Method and Description
ThreadLocal<HistoricalDataCache>	getDataCacheThreadLocal()
ExprEvaluator	getEvaluator()
EventType	getEventType()
HistoricalEventViewableLookupValueToMultiKey	getLookupValueToMultiKey()
int	getScheduleCallbackId()
int	getStreamNumber()
boolean	isHasRequiredStreams()
void	setEvaluator(ExprEvaluator evaluator)
void	setEventType(EventType eventType)
void	setHasRequiredStreams(boolean hasRequiredStreams)
void	setLookupValueToMultiKey(HistoricalEventViewableLookupValueToMultiKey lookupValueToMultiKey)
void	setScheduleCallbackId(int scheduleCallbackId)
void	setStreamNumber(int streamNumber)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.common.internal.epl.historical.common.HistoricalEventViewableFactory

activate

Methods inherited from interface com.espertech.esper.common.internal.context.module.StatementReadyCallback

ready

Field Detail

streamNumber

protected int streamNumber

eventType

protected EventType eventType

hasRequiredStreams

protected boolean hasRequiredStreams

scheduleCallbackId

protected int scheduleCallbackId

evaluator

protected ExprEvaluator evaluator

lookupValueToMultiKey

protected HistoricalEventViewableLookupValueToMultiKey lookupValueToMultiKey

Constructor Detail

HistoricalEventViewableFactoryBase

public HistoricalEventViewableFactoryBase()

Method Detail

getEventType

public EventType getEventType()

Specified by:

getEventType in interface HistoricalEventViewableFactory

setStreamNumber

public void setStreamNumber(int streamNumber)

setEventType

public void setEventType(EventType eventType)

getDataCacheThreadLocal

public ThreadLocal<HistoricalDataCache> getDataCacheThreadLocal()

setHasRequiredStreams

public void setHasRequiredStreams(boolean hasRequiredStreams)

isHasRequiredStreams

public boolean isHasRequiredStreams()

getScheduleCallbackId

public int getScheduleCallbackId()

setScheduleCallbackId

public void setScheduleCallbackId(int scheduleCallbackId)

getStreamNumber

public int getStreamNumber()

getEvaluator

public ExprEvaluator getEvaluator()

setEvaluator

public void setEvaluator(ExprEvaluator evaluator)

getLookupValueToMultiKey

public HistoricalEventViewableLookupValueToMultiKey getLookupValueToMultiKey()

setLookupValueToMultiKey

public void setLookupValueToMultiKey(HistoricalEventViewableLookupValueToMultiKey lookupValueToMultiKey)