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 Summary

  Modifier and Type
  Method
  Description
  `void`
  `decrement()`
  `void`
  `increment()`
  `void`
  `setAcked()`
  `boolean`
  `shouldAck()`
  `String`
  `toString()`
  `Tuple`
  `tuple()`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait`

- ## 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`