Package org.apache.storm.streams

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