public interface ExecutionResultHandler extends Serializable
Default interface to define strategies to apply when a query is either succeed or failed.
| Modifier and Type | Method and Description |
|---|---|
void |
onQuerySuccess(OutputCollector collector,
Tuple tuple)
Invoked when a query is executed with success.
|
void |
onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e,
OutputCollector collector,
Tuple tuple)
Invoked when a
QueryValidationException is thrown. |
void |
onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e,
OutputCollector collector,
Tuple tuple)
Invoked when a
ReadTimeoutException is thrown. |
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.
|
void |
onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e,
OutputCollector collector,
Tuple tuple)
Invoked when a
UnavailableException is thrown. |
void |
onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e,
OutputCollector collector,
Tuple tuple)
Invoked when a
WriteTimeoutException is thrown. |
void onQueryValidationException(com.datastax.driver.core.exceptions.QueryValidationException e,
OutputCollector collector,
Tuple tuple)
Invoked when a QueryValidationException is thrown.
e - the cassandra exception.collector - the storm collector.tuple - an input tuple.void onReadTimeoutException(com.datastax.driver.core.exceptions.ReadTimeoutException e,
OutputCollector collector,
Tuple tuple)
Invoked when a ReadTimeoutException is thrown.
e - the cassandra exception.collector - the storm collector.tuple - an input tuple.void onWriteTimeoutException(com.datastax.driver.core.exceptions.WriteTimeoutException e,
OutputCollector collector,
Tuple tuple)
Invoked when a WriteTimeoutException is thrown.
e - the cassandra exception.collector - the storm collector.tuple - an input tuple.void onUnavailableException(com.datastax.driver.core.exceptions.UnavailableException e,
OutputCollector collector,
Tuple tuple)
Invoked when a UnavailableException is thrown.
e - the cassandra exception.collector - the storm collector.tuple - an input tuple.void onQuerySuccess(OutputCollector collector, Tuple tuple)
Invoked when a query is executed with success. This method is NOT responsible for acknowledging input tuple.
collector - the storm collector.tuple - an input tuple.void onThrowable(Throwable t, OutputCollector collector, Tuple i)
Default method used to handle any type of exception.
t - the thrown exceptioncollector - the storm collector.i - an input tuple.void onThrowable(Throwable t, OutputCollector collector, List<Tuple> tl)
Default method used to handle any type of exception.
t - the thrown exceptioncollector - the storm collector.tl - a list of input tuple.Copyright © 2021 The Apache Software Foundation. All rights reserved.