org.apache.samza.system

Class SystemStreamPartitionIterator

java.lang.Object

org.apache.samza.system.SystemStreamPartitionIterator

All Implemented Interfaces:

java.util.Iterator<IncomingMessageEnvelope>

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

Iterator that wraps a SystemConsumer to iterate over the messages the consumer provides for the specified SystemStreamPartition.

Constructor Summary

Constructors

Constructor and Description
SystemStreamPartitionIterator(SystemConsumer systemConsumer, SystemStreamPartition systemStreamPartition)
SystemStreamPartitionIterator(SystemConsumer systemConsumer, SystemStreamPartition systemStreamPartition, int fetchSize)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SystemStreamPartitionIterator

public SystemStreamPartitionIterator(SystemConsumer systemConsumer,
                             SystemStreamPartition systemStreamPartition)

SystemStreamPartitionIterator

public SystemStreamPartitionIterator(SystemConsumer systemConsumer,
                             SystemStreamPartition systemStreamPartition,
                             int fetchSize)

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>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<IncomingMessageEnvelope>