Class Timer
- java.lang.Object
-
- org.apache.storm.kafka.spout.internal.Timer
-
public class Timer extends Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
delay()
TimeUnit
getTimeUnit()
boolean
isExpiredResetOnTrue()
Checks if a call to this method occurs later thanperiod
since the timer was initiated or reset.long
period()
-
-
-
Constructor Detail
-
Timer
public Timer(long delay, long period, TimeUnit timeUnit)
Creates a class that mimics a single threaded timer that expires periodically. If a call toisExpiredResetOnTrue()
occurs later thanperiod
since the timer was initiated or reset, this method returns true. Each time the method returns true the counter is reset. The timer starts with the specified time delay.- Parameters:
delay
- the initial delay before the timer startsperiod
- the period between callsisExpiredResetOnTrue()
timeUnit
- the time unit of delay and period
-
-
Method Detail
-
period
public long period()
-
delay
public long delay()
-
getTimeUnit
public TimeUnit getTimeUnit()
-
isExpiredResetOnTrue
public boolean isExpiredResetOnTrue()
Checks if a call to this method occurs later thanperiod
since the timer was initiated or reset. If that is the case the method returns true, otherwise it returns false. Each time this method returns true, the counter is reset (re-initiated) and a new cycle will start.- Returns:
- true if the time elapsed since the last call returning true is greater than
period
. Returns false otherwise.
-
-