org.apache.storm.utils

Class BatchHelper

java.lang.Object

org.apache.storm.utils.BatchHelper

public class BatchHelper
extends Object

Constructor Summary

Constructors

Constructor and Description
BatchHelper(int batchSize, OutputCollector collector)

Method Summary

Modifier and Type	Method and Description
void	ack()
void	addBatch(Tuple tuple)
void	fail(Exception e)
int	getBatchSize()
List<Tuple>	getBatchTuples()
boolean	shouldFlush()
boolean	shouldHandle(Tuple tuple)

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchHelper

public BatchHelper(int batchSize,
                   OutputCollector collector)

Method Detail

fail

public void fail(Exception e)

ack

public void ack()

shouldHandle

public boolean shouldHandle(Tuple tuple)

addBatch

public void addBatch(Tuple tuple)

getBatchTuples

public List<Tuple> getBatchTuples()

getBatchSize

public int getBatchSize()

shouldFlush

public boolean shouldFlush()