public static final class ExecutionResultCollector.FailedCollector extends Object implements ExecutionResultCollector
ExecutionResultCollector.FailedCollector, ExecutionResultCollector.SucceedCollector| Constructor and Description |
|---|
FailedCollector(List<Tuple> inputs,
Throwable cause)
Creates a new
ExecutionResultCollector.FailedCollector instance. |
FailedCollector(Tuple input,
Throwable cause)
Creates a new
ExecutionResultCollector.FailedCollector instance. |
| Modifier and Type | Method and Description |
|---|---|
void |
handle(OutputCollector collector,
ExecutionResultHandler handler)
|
public FailedCollector(Tuple input, Throwable cause)
Creates a new ExecutionResultCollector.FailedCollector instance.
input - the input tuple.cause - the cause of the error.public FailedCollector(List<Tuple> inputs, Throwable cause)
Creates a new ExecutionResultCollector.FailedCollector instance.
inputs - the input tuple.cause - the cause of the error.public void handle(OutputCollector collector, ExecutionResultHandler handler)
handle in interface ExecutionResultCollectorCopyright © 2021 The Apache Software Foundation. All rights reserved.