public abstract class AbstractExecutionResultHandler extends Object implements ExecutionResultHandler
Default interface to define strategies to apply when a query is either succeed or failed.
| Modifier and Type | Field and Description |
|---|---|
static org.slf4j.Logger |
LOG |
| Constructor and Description |
|---|
AbstractExecutionResultHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
onThrowable(Throwable t,
OutputCollector collector,
List<Tuple> tl)
Default method used to handle any type of exception.
|
void |
onThrowable(Throwable t,
OutputCollector collector,
Tuple i)
Default method used to handle any type of exception.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonQuerySuccess, onQueryValidationException, onReadTimeoutException, onUnavailableException, onWriteTimeoutExceptionpublic void onThrowable(Throwable t, OutputCollector collector, Tuple i)
ExecutionResultHandlerDefault method used to handle any type of exception.
onThrowable in interface ExecutionResultHandlert - the thrown exceptioncollector - the storm collector.i - an input tuple.public void onThrowable(Throwable t, OutputCollector collector, List<Tuple> tl)
ExecutionResultHandlerDefault method used to handle any type of exception.
onThrowable in interface ExecutionResultHandlert - the thrown exceptioncollector - the storm collector.tl - a list of input tuple.Copyright © 2021 The Apache Software Foundation. All rights reserved.