public class BatchAsyncResultHandler extends Object implements AsyncResultHandler<List<Tuple>>
NO_OP_HANDLER| Constructor and Description |
|---|
BatchAsyncResultHandler(ExecutionResultHandler handler)
Creates a new
BatchAsyncResultHandler instance. |
| Modifier and Type | Method and Description |
|---|---|
void |
failure(Throwable t,
List<Tuple> input)
This method is responsible for failing specified inputs.
|
void |
flush(OutputCollector collector) |
void |
success(List<Tuple> input)
This method is responsible for acknowledging specified inputs.
|
public BatchAsyncResultHandler(ExecutionResultHandler handler)
Creates a new BatchAsyncResultHandler instance.
public void failure(Throwable t, List<Tuple> input)
This method is responsible for failing specified inputs.
The default method does no-operation.
failure in interface AsyncResultHandler<List<Tuple>>t - The cause the failure.input - The input tuple proceed.public void success(List<Tuple> input)
This method is responsible for acknowledging specified inputs.
The default method does no-operation.
success in interface AsyncResultHandler<List<Tuple>>input - The input tuple proceed.public void flush(OutputCollector collector)
flush in interface AsyncResultHandler<List<Tuple>>Copyright © 2021 The Apache Software Foundation. All rights reserved.