com.espertech.esper.epl.view
Class OutputConditionExpression

java.lang.Object
  com.espertech.esper.epl.view.OutputConditionBase
      com.espertech.esper.epl.view.OutputConditionExpression

All Implemented Interfaces:

VariableChangeCallback, OutputCondition, StopCallback

public class OutputConditionExpression
extends OutputConditionBase
implements OutputCondition, VariableChangeCallback, StopCallback

Output condition for output rate limiting that handles when-then expressions for controlling output.

Field Summary

Fields inherited from class com.espertech.esper.epl.view.OutputConditionBase

outputCallback

Constructor Summary

OutputConditionExpression(OutputCallback outputCallback, AgentInstanceContext agentInstanceContext, OutputConditionExpressionFactory parent, boolean isStartConditionOnCreation)

Method Summary

void	stop() Stops the underlying resources.
void	terminated()
void	update(java.lang.Object newValue, java.lang.Object oldValue) Indicate a change in variable value.
void	updateOutputCondition(int newEventsCount, int oldEventsCount) Update the output condition.

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputConditionExpression

public OutputConditionExpression(OutputCallback outputCallback,
                                 AgentInstanceContext agentInstanceContext,
                                 OutputConditionExpressionFactory parent,
                                 boolean isStartConditionOnCreation)

Method Detail

updateOutputCondition

public void updateOutputCondition(int newEventsCount,
                                  int oldEventsCount)

Description copied from interface: OutputCondition

Update the output condition.

Specified by:

updateOutputCondition in interface OutputCondition

Parameters:

newEventsCount - - number of new events incoming

oldEventsCount - - number of old events incoming

update

public void update(java.lang.Object newValue,
                   java.lang.Object oldValue)

Description copied from interface: VariableChangeCallback

Indicate a change in variable value.

Specified by:

update in interface VariableChangeCallback

Parameters:

newValue - new value

oldValue - old value

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

terminated

public void terminated()

Specified by:

terminated in interface OutputCondition

Overrides:

terminated in class OutputConditionBase