public class BufferAction<T> extends BatchAction<T> implements Flushable<T>
| Modifier and Type | Field and Description |
|---|---|
static Event<java.lang.Object> |
BUFFER_FLUSH |
lockFLUSH_EVENT| Constructor and Description |
|---|
BufferAction(int batchSize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey,
java.lang.Object flushKey) |
| Modifier and Type | Method and Description |
|---|---|
void |
doFlush(Event<T> value) |
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 static final Event<java.lang.Object> BUFFER_FLUSH
public BufferAction(int batchSize,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey,
java.lang.Object flushKey)
public void doNext(Event<T> value)
doNext in class BatchAction<T>public void doFlush(Event<T> value)
doFlush in class BatchAction<T>