org.apache.storm.cassandra

Class AbstractExecutionResultHandler

java.lang.Object

org.apache.storm.cassandra.AbstractExecutionResultHandler

All Implemented Interfaces:

Serializable, ExecutionResultHandler

Direct Known Subclasses:

BaseExecutionResultHandler

public abstract class AbstractExecutionResultHandler
extends Object
implements ExecutionResultHandler

Default interface to define strategies to apply when a query is either succeed or failed.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
AbstractExecutionResultHandler()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.cassandra.ExecutionResultHandler

onQuerySuccess, onQueryValidationException, onReadTimeoutException, onUnavailableException, onWriteTimeoutException

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

AbstractExecutionResultHandler

public AbstractExecutionResultHandler()

Method Detail

onThrowable

public void onThrowable(Throwable t,
                        OutputCollector collector,
                        Tuple i)

Description copied from interface: ExecutionResultHandler

Default method used to handle any type of exception.

Specified by:

onThrowable in interface ExecutionResultHandler

Parameters:

t - the thrown exception

collector - the storm collector.

i - an input tuple.

onThrowable

public void onThrowable(Throwable t,
                        OutputCollector collector,
                        List<Tuple> tl)

Description copied from interface: ExecutionResultHandler

Default method used to handle any type of exception.

Specified by:

onThrowable in interface ExecutionResultHandler

Parameters:

t - the thrown exception

collector - the storm collector.

tl - a list of input tuple.