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 © 2022 The Apache Software Foundation. All rights reserved.