Package org.apache.flink.api.java.operators.translation

Class Tuple3UnwrappingIterator<T,​K1,​K2>

  • All Implemented Interfaces:
    Serializable, Iterable<T>, Iterator<T>
    @Internal
public class Tuple3UnwrappingIterator<T,​K1,​K2>
extends Object
implements Iterator<T>, Iterable<T>, Serializable
    An iterator that reads 3-tuples (groupKey, sortKey, value) and returns only the values (third field). The iterator also tracks the groupKeys, as the triples flow though it.
    See Also:
    Serialized Form

    • Constructor Detail

      • Tuple3UnwrappingIterator

        public Tuple3UnwrappingIterator()

    • Method Detail

      • set

        public void set​(Iterator<org.apache.flink.api.java.tuple.Tuple3<K1,​K2,​T>> iterator)

      • getLastGroupKey

        public K1 getLastGroupKey()

      • getLastSortKey

        public K2 getLastSortKey()

      • hasNext

        public boolean hasNext()
        Specified by:
        hasNext in interface Iterator<T>

      • next

        public T next()
        Specified by:
        next in interface Iterator<T>

      • remove

        public void remove()
        Specified by:
        remove in interface Iterator<T>