org.apache.samza.system

Class BoundedSSPIterator

java.lang.Object

org.apache.samza.system.BoundedSSPIterator

All Implemented Interfaces:

java.util.Iterator<IncomingMessageEnvelope>

Direct Known Subclasses:

ChangelogSSPIterator

public class BoundedSSPIterator
extends java.lang.Object
implements java.util.Iterator<IncomingMessageEnvelope>

Iterates over messages in the provided SystemStreamPartition using the provided SystemConsumer until all messages with offsets up to and including the endOffset have been consumed. If endOffset is null, the iterator will return all messages until caught up to head.

Field Summary

Fields

Modifier and Type	Field and Description
protected SystemAdmin	admin

Constructor Summary

Constructors

Constructor and Description
BoundedSSPIterator(SystemConsumer systemConsumer, SystemStreamPartition systemStreamPartition, java.lang.String endOffset, SystemAdmin admin)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
IncomingMessageEnvelope	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Field Detail

admin

protected final SystemAdmin admin

Constructor Detail

BoundedSSPIterator

public BoundedSSPIterator(SystemConsumer systemConsumer,
                          SystemStreamPartition systemStreamPartition,
                          java.lang.String endOffset,
                          SystemAdmin admin)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<IncomingMessageEnvelope>

next

public IncomingMessageEnvelope next()

Specified by:

next in interface java.util.Iterator<IncomingMessageEnvelope>