public class MovingWindowAction<T> extends WindowAction<T>
FLUSH_EVENT| Constructor and Description |
|---|
MovingWindowAction(Observable d,
java.lang.Object successKey,
java.lang.Object failureKey,
Timer timer,
int period,
java.util.concurrent.TimeUnit timeUnit,
int delay,
int backlog) |
| Modifier and Type | Method and Description |
|---|---|
void |
doAccept(Event<T> value) |
protected void |
doWindow(java.lang.Long aLong) |
cancel, flush, pause, resumeaccept, getFailureKey, getObservable, getSuccessKey, notifyError, notifyValue, toStringpublic MovingWindowAction(Observable d, java.lang.Object successKey, java.lang.Object failureKey, Timer timer, int period, java.util.concurrent.TimeUnit timeUnit, int delay, int backlog)
protected void doWindow(java.lang.Long aLong)
doWindow in class WindowAction<T>public void doAccept(Event<T> value)
doAccept in class WindowAction<T>