public class SimpleDequeueResult extends DequeueResult
DequeueResult
DequeueResult.Interceptor
CLOSED, GOOD, leadershipStatus, props, throwable, TIMEOUT
Constructor and Description |
---|
SimpleDequeueResult(java.util.List<Tuple> tuples,
StreamProperties props,
StreamBaseURI server,
Constants.LeadershipStatus leadershipStatus) |
Modifier and Type | Method and Description |
---|---|
int |
getTupleCount()
Returns the number of tuples dequeued.
|
java.util.Iterator<Tuple> |
iterator()
Returns an iterator of all tuples.
|
checkStatus, getLeadershipStatus, getSchema, getServerURI, getStatus, getStreamName, getStreamProperties
public SimpleDequeueResult(java.util.List<Tuple> tuples, StreamProperties props, StreamBaseURI server, Constants.LeadershipStatus leadershipStatus)
public int getTupleCount()
DequeueResult
getTupleCount
in class DequeueResult
public java.util.Iterator<Tuple> iterator()
DequeueResult
iterator
in interface java.lang.Iterable<Tuple>
iterator
in class DequeueResult