Package org.apache.storm.utils

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