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

Class TimerAtObserverForge

java.lang.Object

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

All Implemented Interfaces:

ObserverForge, ScheduleHandleCallbackProvider

public class TimerAtObserverForge
extends Object
implements ObserverForge, ScheduleHandleCallbackProvider

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

Constructor Summary

Constructors

Constructor	Description
TimerAtObserverForge()

Method Summary

Modifier and Type	Method	Description
void	collectSchedule(short factoryNodeId, Function<Short,CallbackAttribution> callbackAttribution, List<ScheduleHandleTracked> schedules)
int	getScheduleCallbackId()
CodegenExpression	makeCodegen(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope)
void	setObserverParameters(List<ExprNode> parameters, MatchedEventConvertorForge convertor, ExprValidationContext validationContext)	Sets the observer object parameters.
void	setScheduleCallbackId(int id)

Methods inherited from class java.lang.Object

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

Constructor Details

TimerAtObserverForge

public TimerAtObserverForge()

Method Details

setObserverParameters

public void setObserverParameters(List<ExprNode> parameters,
 MatchedEventConvertorForge convertor,
 ExprValidationContext validationContext)
                           throws ObserverParameterException

Description copied from interface: ObserverForge

Sets the observer object parameters.

Specified by:

setObserverParameters in interface ObserverForge

Parameters:

parameters - is a list of parameters

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

validationContext - context

Throws:

ObserverParameterException - thrown to indicate a parameter problem

makeCodegen

public CodegenExpression makeCodegen(CodegenMethodScope parent,
 SAIFFInitializeSymbol symbols,
 CodegenClassScope classScope)

Specified by:

makeCodegen in interface ObserverForge

collectSchedule

public void collectSchedule(short factoryNodeId,
 Function<Short,CallbackAttribution> callbackAttribution,
 List<ScheduleHandleTracked> schedules)

Specified by:

collectSchedule in interface ObserverForge

setScheduleCallbackId

public void setScheduleCallbackId(int id)

Specified by:

setScheduleCallbackId in interface ScheduleHandleCallbackProvider

getScheduleCallbackId

public int getScheduleCallbackId()

Specified by:

getScheduleCallbackId in interface ScheduleHandleCallbackProvider