Uses of Interface
org.apache.flink.runtime.util.KeyGroupedIterator

Packages that use KeyGroupedIterator

Package	Description
org.apache.flink.runtime.operators.sort
org.apache.flink.runtime.util

Uses of KeyGroupedIterator in org.apache.flink.runtime.operators.sort

Fields in org.apache.flink.runtime.operators.sort declared as KeyGroupedIterator

Modifier and Type	Field and Description
protected KeyGroupedIterator<T1>	AbstractMergeIterator.iterator1
protected KeyGroupedIterator<T2>	AbstractMergeIterator.iterator2

Methods in org.apache.flink.runtime.operators.sort that return KeyGroupedIterator

Modifier and Type	Method and Description
protected <T> KeyGroupedIterator<T>	ReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected abstract <T> KeyGroupedIterator<T>	AbstractMergeIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected <T> KeyGroupedIterator<T>	ReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected <T> KeyGroupedIterator<T>	NonReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected <T> KeyGroupedIterator<T>	NonReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)

Uses of KeyGroupedIterator in org.apache.flink.runtime.util

Classes in org.apache.flink.runtime.util that implement KeyGroupedIterator

Modifier and Type	Class and Description
class	NonReusingKeyGroupedIterator<E> The key grouped iterator returns a key and all values that share the same key.
class	ReusingKeyGroupedIterator<E> The KeyValueIterator returns a key and all values that belong to the key (share the same key).