org.apache.storm.cassandra.bolt

Class PairBatchStatementTuples

java.lang.Object

org.apache.storm.cassandra.bolt.PairBatchStatementTuples

public class PairBatchStatementTuples
extends Object

Simple class to pair a list of tuples with a single batch statement.

Constructor Summary

Constructors

Constructor and Description
PairBatchStatementTuples(List<Tuple> inputs, com.datastax.driver.core.BatchStatement statement) Creates a new PairBatchStatementTuples instance.

Method Summary

Modifier and Type	Method and Description
List<Tuple>	getInputs()
com.datastax.driver.core.BatchStatement	getStatement()

Methods inherited from class java.lang.Object

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

Constructor Detail

PairBatchStatementTuples

public PairBatchStatementTuples(List<Tuple> inputs,
                                com.datastax.driver.core.BatchStatement statement)

Creates a new PairBatchStatementTuples instance.

Parameters:

inputs - List of inputs attached to this batch.

statement - The batch statement.

Method Detail

getInputs

public List<Tuple> getInputs()

getStatement

public com.datastax.driver.core.BatchStatement getStatement()