org.apache.storm.cassandra.executor

Interface AsyncResultSetHandler<T>

All Superinterfaces:

Serializable

public interface AsyncResultSetHandler<T>
extends Serializable

Default handler for batch asynchronous execution.

Field Summary

Fields

Modifier and Type	Field and Description
static AsyncResultSetHandler	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	success(T inputs, com.datastax.driver.core.ResultSet resultSet) This method is responsible for acknowledging specified inputs.

Field Detail

NO_OP_HANDLER

static final AsyncResultSetHandler 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,
             com.datastax.driver.core.ResultSet resultSet)

This method is responsible for acknowledging specified inputs.

Parameters:

inputs - The input tuple proceed.