public class ReduceAction<T,A> extends BatchAction<T> implements Flushable<T>
lockFLUSH_EVENT| Constructor and Description |
|---|
ReduceAction(int batchSize,
Supplier<A> accumulators,
Function<Tuple2<T,A>,A> fn,
Observable d,
java.lang.Object successKey,
java.lang.Object failureKey) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doFlush(Event<T> ev) |
protected void |
doNext(Event<T> ev) |
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, notifyValueprotected void doNext(Event<T> ev)
doNext in class BatchAction<T>protected void doFlush(Event<T> ev)
doFlush in class BatchAction<T>