Package io.confluent.csid.utils

Class LoopingResumingIterator<KEY,VALUE>

java.lang.Object

io.confluent.csid.utils.LoopingResumingIterator<KEY,VALUE>

All Implemented Interfaces:

Iterable<Map.Entry<KEY,VALUE>>, Iterator<Map.Entry<KEY,VALUE>>

public class LoopingResumingIterator<KEY,VALUE>
extends Object
implements Iterator<Map.Entry<KEY,VALUE>>, Iterable<Map.Entry<KEY,VALUE>>

Loop implementations that will resume from a given key. Can be constructed and used as an iterable, or a function passed into the static version #iterateStartingFromKeyLooping.

The non functional version is useful when you want to use looping constructs such as break and continue.

Constructor Summary

Constructors

Constructor	Description
LoopingResumingIterator(Map<KEY,VALUE> map)
LoopingResumingIterator(Optional<KEY> startingKey, Map<KEY,VALUE> map)	Will resume from the startingKey, if it's present

Method Summary

Modifier and Type	Method	Description
static <KKEY, VVALUE> LoopingResumingIterator<KKEY,VVALUE>	build(KKEY startingKey, Map<KKEY,VVALUE> map)
Optional<KEY>	getIterationStartingPoint()
boolean	hasNext()
Iterator<Map.Entry<KEY,VALUE>>	iterator()
Map.Entry<KEY,VALUE>	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Details

LoopingResumingIterator

public LoopingResumingIterator(Optional<KEY> startingKey,
 Map<KEY,VALUE> map)

Will resume from the startingKey, if it's present

LoopingResumingIterator

public LoopingResumingIterator(Map<KEY,VALUE> map)

Method Details

build

public static <KKEY,
VVALUE>
LoopingResumingIterator<KKEY,VVALUE> build(KKEY startingKey,
 Map<KKEY,VVALUE> map)

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<KEY>

next

public Map.Entry<KEY,VALUE> next()

Specified by:

next in interface Iterator<KEY>

iterator

public Iterator<Map.Entry<KEY,VALUE>> iterator()

Specified by:

iterator in interface Iterable<KEY>

getIterationStartingPoint

public Optional<KEY> getIterationStartingPoint()