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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
decrement()
void
increment()
void
setAcked()
boolean
shouldAck()
String
toString()
Tuple
tuple()
-