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

Class OutputConditionCount

java.lang.Object

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

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

All Implemented Interfaces:

OutputCondition

public final class OutputConditionCount
extends OutputConditionBase
implements OutputCondition

Output limit condition that is satisfied when either the total number of new events arrived or the total number of old events arrived is greater than a preset value.

Field Summary

Fields inherited from class com.espertech.esper.common.internal.epl.output.condition.OutputConditionBase

outputCallback

Fields inherited from interface com.espertech.esper.common.internal.epl.output.condition.OutputCondition

EPTYPE

Constructor Summary

Constructors

Constructor	Description
OutputConditionCount(OutputCallback outputCallback, long eventRate, VariableReader variableReader)

Method Summary

Modifier and Type	Method	Description
int	getNewEventsCount()	Returns the number of new events.
int	getOldEventsCount()	Returns the number of old events.
void	stopOutputCondition()
void	terminated()
final String	toString()
final void	updateOutputCondition(int newDataCount, int oldDataCount)	Update the output condition.

Methods inherited from class java.lang.Object

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

Constructor Details

OutputConditionCount

public OutputConditionCount(OutputCallback outputCallback,
 long eventRate,
 VariableReader variableReader)

Method Details

getNewEventsCount

public int getNewEventsCount()

Returns the number of new events.

Returns:

number of new events

getOldEventsCount

public int getOldEventsCount()

Returns the number of old events.

Returns:

number of old events

updateOutputCondition

public final void updateOutputCondition(int newDataCount,
 int oldDataCount)

Description copied from interface: OutputCondition

Update the output condition.

Specified by:

updateOutputCondition in interface OutputCondition

Parameters:

newDataCount - - number of new events incoming

oldDataCount - - number of old events incoming

toString

public final String toString()

Overrides:

toString in class Object

terminated

public void terminated()

Specified by:

terminated in interface OutputCondition

Overrides:

terminated in class OutputConditionBase

stopOutputCondition

public void stopOutputCondition()

Specified by:

stopOutputCondition in interface OutputCondition