org.apache.storm.cassandra.executor

Interface AsyncResultHandler<T>

All Superinterfaces:

Serializable

All Known Implementing Classes:

BatchAsyncResultHandler, SingleAsyncResultHandler

public interface AsyncResultHandler<T>
extends Serializable

Default handler for batch asynchronous execution.

Field Summary

Fields

Modifier and Type	Field and Description
static AsyncResultHandler	NO_OP_HANDLER

Method Summary

Modifier and Type	Method and Description
void	failure(Throwable t, T inputs) This method is responsible for failing specified inputs.
void	flush(OutputCollector collector)
void	success(T inputs) This method is responsible for acknowledging specified inputs.

Field Detail

NO_OP_HANDLER

static final AsyncResultHandler NO_OP_HANDLER

Method Detail

failure

void failure(Throwable t,
             T inputs)

This method is responsible for failing specified inputs.

Parameters:

t - The cause the failure.

inputs - The input tuple proceed.

success

void success(T inputs)

This method is responsible for acknowledging specified inputs.

Parameters:

inputs - The input tuple proceed.

flush

void flush(OutputCollector collector)