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

Class TimerScheduleObserverForge

java.lang.Object

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

All Implemented Interfaces:

ObserverForge, ScheduleHandleCallbackProvider

public class TimerScheduleObserverForge
extends Object
implements ObserverForge, ScheduleHandleCallbackProvider

Factory for ISO8601 repeating interval observers that indicate truth when a time point was reached.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	NAME_OBSERVER

Constructor Summary

Constructors

Constructor	Description
TimerScheduleObserverForge()

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

Field Details

NAME_OBSERVER

protected static final String NAME_OBSERVER

See Also:

• Constant Field Values

Constructor Details

TimerScheduleObserverForge

public TimerScheduleObserverForge()

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

setScheduleCallbackId

public void setScheduleCallbackId(int id)

Specified by:

setScheduleCallbackId in interface ScheduleHandleCallbackProvider

getScheduleCallbackId

public int getScheduleCallbackId()

Specified by:

getScheduleCallbackId in interface ScheduleHandleCallbackProvider

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