Class BatchHelper

java.lang.Object
org.apache.storm.utils.BatchHelper

public class BatchHelper extends Object
  • Constructor Details

    • BatchHelper

      public BatchHelper(int batchSize, OutputCollector collector)
  • Method Details

    • 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()