Class 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 Detail

      • shouldAck

        public boolean shouldAck()
      • increment

        public void increment()
      • decrement

        public void decrement()
      • tuple

        public Tuple tuple()
      • setAcked

        public void setAcked()