com.espertech.esper.pattern.observer
Class TimerAtObserverFactory

java.lang.Object
  com.espertech.esper.pattern.observer.TimerAtObserverFactory

All Implemented Interfaces:

ObserverFactory, MetaDefItem, java.io.Serializable

public class TimerAtObserverFactory
extends java.lang.Object
implements ObserverFactory, MetaDefItem, java.io.Serializable

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

See Also:

Serialized Form

Field Summary

protected MatchedEventConvertor	convertor Convertor.
protected java.util.List<ExprNode>	parameters Parameters.
protected ScheduleSpec	spec The schedule specification for the timer-at.

Constructor Summary

TimerAtObserverFactory()

Method Summary

protected ScheduleSpec	computeSpec(MatchedEventMap beginState, PatternAgentInstanceContext context)
boolean	isNonRestarting()
EventObserver	makeObserver(PatternAgentInstanceContext context, MatchedEventMap beginState, ObserverEventEvaluator observerEventEvaluator, EvalStateNodeNumber stateNodeId, java.lang.Object observerState, boolean isFilterChildNonQuitting) Make an observer instance.
void	setObserverParameters(java.util.List<ExprNode> parameters, MatchedEventConvertor convertor) Sets the observer object parameters.

Methods inherited from class java.lang.Object

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

Field Detail

parameters

protected java.util.List<ExprNode> parameters

Parameters.

convertor

protected transient MatchedEventConvertor convertor

Convertor.

spec

protected ScheduleSpec spec

The schedule specification for the timer-at.

Constructor Detail

TimerAtObserverFactory

public TimerAtObserverFactory()

Method Detail

setObserverParameters

public void setObserverParameters(java.util.List<ExprNode> parameters,
                                  MatchedEventConvertor convertor)
                           throws ObserverParameterException

Description copied from interface: ObserverFactory

Sets the observer object parameters.

Specified by:

setObserverParameters in interface ObserverFactory

Parameters:

parameters - is a list of parameters

convertor - for converting partial pattern matches to event-per-stream for expressions

Throws:

ObserverParameterException - thrown to indicate a parameter problem

computeSpec

protected ScheduleSpec computeSpec(MatchedEventMap beginState,
                                   PatternAgentInstanceContext context)

makeObserver

public EventObserver makeObserver(PatternAgentInstanceContext context,
                                  MatchedEventMap beginState,
                                  ObserverEventEvaluator observerEventEvaluator,
                                  EvalStateNodeNumber stateNodeId,
                                  java.lang.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

stateNodeId - - optional id for the associated pattern state node

observerState - - state node for observer

Returns:

observer instance

isNonRestarting

public boolean isNonRestarting()

Specified by:

isNonRestarting in interface ObserverFactory