Package org.apache.wayang.flink.operators

Class CollectionSplittableIterator<T>

java.lang.Object

org.apache.flink.util.SplittableIterator<T>

org.apache.wayang.flink.operators.CollectionSplittableIterator<T>

All Implemented Interfaces:

Serializable, Iterator<T>

public class CollectionSplittableIterator<T>
extends org.apache.flink.util.SplittableIterator<T>
implements Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CollectionSplittableIterator(List<T> collection, int numSplits)

Method Summary

Modifier and Type	Method	Description
int	getMaximumNumberOfSplits()
boolean	hasNext()
T	next()
Iterator<T>[]	split(int numSplits)

Methods inherited from class org.apache.flink.util.SplittableIterator

getSplit

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

Constructor Details

CollectionSplittableIterator

public CollectionSplittableIterator(List<T> collection,
 int numSplits)

Method Details

split

public Iterator<T>[] split(int numSplits)

Specified by:

split in class org.apache.flink.util.SplittableIterator<T>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<T>

next

public T next()

Specified by:

next in interface Iterator<T>

getMaximumNumberOfSplits

public int getMaximumNumberOfSplits()

Specified by:

getMaximumNumberOfSplits in class org.apache.flink.util.SplittableIterator<T>