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

Class TimerIntervalObserverForge

java.lang.Object

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

All Implemented Interfaces:

ObserverForge, ScheduleHandleCallbackProvider

public class TimerIntervalObserverForge
extends Object
implements ObserverForge, ScheduleHandleCallbackProvider

Factory for making observer instances.

Field Summary

Fields

Modifier and Type	Field	Description
protected MatchedEventConvertorForge	convertor
protected ExprNode	parameter
protected int	scheduleCallbackId
protected TimeAbacus	timeAbacus

Constructor Summary

Constructors

Constructor	Description
TimerIntervalObserverForge()

Method Summary

Modifier and Type	Method	Description
void	collectSchedule(short factoryNodeId, Function<Short,CallbackAttribution> scheduleAttribution, 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

parameter

protected ExprNode parameter

scheduleCallbackId

protected int scheduleCallbackId

timeAbacus

protected TimeAbacus timeAbacus

convertor

protected MatchedEventConvertorForge convertor

Constructor Details

TimerIntervalObserverForge

public TimerIntervalObserverForge()

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

collectSchedule

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

Specified by:

collectSchedule in interface ObserverForge

makeCodegen

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

Specified by:

makeCodegen in interface ObserverForge