Package org.apache.storm.streams
Class RefCountedTuple
java.lang.Object
org.apache.storm.streams.RefCountedTuple
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