org.apache.samza.system

Class ChangelogSSPIterator

java.lang.Object

org.apache.samza.system.ChangelogSSPIterator

public class ChangelogSSPIterator
extends java.lang.Object

Iterates over messages in the provided changelog SystemStreamPartition using the provided SystemConsumer until all messages have been consumed. The iterator has a ChangelogSSPIterator.Mode that depends on its position in the changelog SSP. If trim mode is enabled, the mode switches to TRIM if the current message offset is greater than the provided endOffset, or if endOffset is null. The iterator mode is used during transactional state restore to determine which changelog SSP entries should be restored and which ones need to be reverted / trimmed from the changelog topic.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChangelogSSPIterator.Mode

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
ChangelogSSPIterator.Mode	getMode()
boolean	hasNext()
IncomingMessageEnvelope	next()

Methods inherited from class java.lang.Object

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

Constructor Detail

ChangelogSSPIterator

public ChangelogSSPIterator(SystemConsumer systemConsumer,
                            SystemStreamPartition systemStreamPartition,
                            java.lang.String endOffset,
                            SystemAdmin admin,
                            boolean trimEnabled)

Method Detail

hasNext

public boolean hasNext()

next

public IncomingMessageEnvelope next()

getMode

public ChangelogSSPIterator.Mode getMode()