Package com.espertech.esper.common.internal.epl.pattern.observer

Class TimerAtObserverFactory

java.lang.Object

com.espertech.esper.common.internal.epl.pattern.observer.TimerAtObserverFactory

All Implemented Interfaces:

ObserverFactory

public class TimerAtObserverFactory
extends Object
implements ObserverFactory

Factory for 'crontab' observers that indicate truth when a time point was reached.

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Constructor Summary

Constructors

Constructor	Description
TimerAtObserverFactory()

Method Summary

Modifier and Type	Method	Description
ScheduleSpec	computeSpec(MatchedEventMap beginState, PatternAgentInstanceContext context)
boolean	isNonRestarting()
EventObserver	makeObserver(PatternAgentInstanceContext context, MatchedEventMap beginState, ObserverEventEvaluator observerEventEvaluator, Object observerState, boolean isFilterChildNonQuitting)	Make an observer instance.
void	setOptionalConvertor(MatchedEventConvertor optionalConvertor)
void	setParameters(ExprEvaluator[] parameters)
void	setScheduleCallbackId(int scheduleCallbackId)
void	setSpec(ScheduleSpec spec)

Methods inherited from class java.lang.Object

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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Details

TimerAtObserverFactory

public TimerAtObserverFactory()

Method Details

setParameters

public void setParameters(ExprEvaluator[] parameters)

setOptionalConvertor

public void setOptionalConvertor(MatchedEventConvertor optionalConvertor)

setSpec

public void setSpec(ScheduleSpec spec)

setScheduleCallbackId

public void setScheduleCallbackId(int scheduleCallbackId)

computeSpec

public ScheduleSpec computeSpec(MatchedEventMap beginState,
 PatternAgentInstanceContext context)

makeObserver

public EventObserver makeObserver(PatternAgentInstanceContext context,
 MatchedEventMap beginState,
 ObserverEventEvaluator observerEventEvaluator,
 Object observerState,
 boolean isFilterChildNonQuitting)

Description copied from interface: ObserverFactory

Make an observer instance.

Specified by:

makeObserver in interface ObserverFactory

Parameters:

context - - services that may be required by observer implementation

beginState - - start state for observer

observerEventEvaluator - - receiver for events observed

observerState - - state node for observer

isFilterChildNonQuitting - true for non-quitting filter

Returns:

observer instance

isNonRestarting

public boolean isNonRestarting()

Specified by:

isNonRestarting in interface ObserverFactory