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