Class RefCountedTuple

java.lang.Object
org.apache.storm.streams.RefCountedTuple

public class RefCountedTuple extends Object
Provides reference counting of tuples. Used when operations that operate on a batch of tuples are involved (e.g. aggregation, join etc). The input tuples are acked once the result is emitted downstream.
  • Method Details

    • shouldAck

      public boolean shouldAck()
    • increment

      public void increment()
    • decrement

      public void decrement()
    • tuple

      public Tuple tuple()
    • setAcked

      public void setAcked()
    • toString

      public String toString()
      Overrides:
      toString in class Object