org.apache.storm.cassandra.bolt

Class GroupingBatchBuilder

java.lang.Object

org.apache.storm.cassandra.bolt.GroupingBatchBuilder

All Implemented Interfaces:

Iterable<PairBatchStatementTuples>

public class GroupingBatchBuilder
extends Object
implements Iterable<PairBatchStatementTuples>

Constructor Summary

Constructors

Constructor and Description
GroupingBatchBuilder(int batchSizeRows, List<PairStatementTuple> statements) Creates a new GroupingBatchBuilder instance.

Method Summary

Modifier and Type	Method and Description
Iterator<PairBatchStatementTuples>	iterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

GroupingBatchBuilder

public GroupingBatchBuilder(int batchSizeRows,
                            List<PairStatementTuple> statements)

Creates a new GroupingBatchBuilder instance.

Parameters:

batchSizeRows -

Method Detail

iterator

public Iterator<PairBatchStatementTuples> iterator()

Specified by:

iterator in interface Iterable<PairBatchStatementTuples>