public class CollectAction<T> extends BatchAction<T> implements Flushable<T>
lockFLUSH_EVENT| Constructor and Description |
|---|
CollectAction(int batchsize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey) |
| Modifier and Type | Method and Description |
|---|---|
void |
doFlush(Event<T> ev) |
void |
doNext(Event<T> value) |
Flushable<T> |
flush()
Trigger flush on this component, generally draining any collected values.
|
doAccept, doFirst, getAcceptCount, getBatchSize, getErrorCount, getFirstKey, getFlushKey, notifyError, toStringaccept, getFailureKey, getObservable, getSuccessKey, notifyValuepublic CollectAction(int batchsize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey)
public void doNext(Event<T> value)
doNext in class BatchAction<T>public void doFlush(Event<T> ev)
doFlush in class BatchAction<T>