com.espertech.esper.common.internal.epl.output.condition

Class OutputConditionCountFactory

java.lang.Object

com.espertech.esper.common.internal.epl.output.condition.OutputConditionCountFactory

All Implemented Interfaces:

OutputConditionFactory

public class OutputConditionCountFactory
extends Object
implements OutputConditionFactory

Field Summary

Fields

Modifier and Type	Field and Description
static EPTypeClass	EPTYPE
protected long	eventRate
protected StateMgmtSetting	stateMgmtSetting
protected Variable	variable

Constructor Summary

Constructors

Constructor and Description
OutputConditionCountFactory(int eventRate, Variable variable, StateMgmtSetting stateMgmtSetting) Constructor.

Method Summary

Modifier and Type	Method and Description
long	getEventRate()
Object	getVariable()
OutputCondition	instantiateOutputCondition(AgentInstanceContext agentInstanceContext, OutputCallback outputCallback)

Methods inherited from class java.lang.Object

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

Field Detail

EPTYPE

public static final EPTypeClass EPTYPE

eventRate

protected final long eventRate

variable

protected final Variable variable

stateMgmtSetting

protected final StateMgmtSetting stateMgmtSetting

Constructor Detail

OutputConditionCountFactory

public OutputConditionCountFactory(int eventRate,
                                   Variable variable,
                                   StateMgmtSetting stateMgmtSetting)

Constructor.

Parameters:

eventRate - is the number of old or new events that must arrive in order for the condition to be satisfied

variable - variable

stateMgmtSetting - state management settings

Method Detail

instantiateOutputCondition

public OutputCondition instantiateOutputCondition(AgentInstanceContext agentInstanceContext,
                                                  OutputCallback outputCallback)

Specified by:

instantiateOutputCondition in interface OutputConditionFactory

getEventRate

public long getEventRate()

getVariable

public Object getVariable()