com.eventgnosis.filters
Class CountUniqueRec

java.lang.Object
  extended bycom.eventgnosis.filters.CountUniqueRec
All Implemented Interfaces:
IsExpired

public class CountUniqueRec
extends java.lang.Object
implements IsExpired

Tuple including count value and expiration timer.
The timer starts at the arrival of the first event.


Constructor Summary
CountUniqueRec(long expTime)
          Creates a new instance of CountUniqueRec.
 
Method Summary
 long getCount()
           
 java.lang.String getRuntimeXml()
           
 void incrementCount()
          Increments the count.
 boolean isExpired()
          Checks out if time of counting is expired.
 void reset()
          Resets timer and counter.
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

CountUniqueRec

public CountUniqueRec(long expTime)
Creates a new instance of CountUniqueRec.

Parameters:
expTime - - expiration time in milliseconds
Method Detail

getCount

public long getCount()
Returns:
Current count towards threshold.

getRuntimeXml

public java.lang.String getRuntimeXml()
Returns:
built XML relating to runtime

incrementCount

public void incrementCount()
Increments the count.


isExpired

public boolean isExpired()
Checks out if time of counting is expired.

Specified by:
isExpired in interface IsExpired
Returns:
true if time of counting is expired; otherwise false
See Also:
IsExpired.isExpired()

reset

public void reset()
Resets timer and counter.


toString

public java.lang.String toString()