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

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