org.apache.flink.hadoopcompatibility.mapred.wrapper

Class HadoopTupleUnwrappingIterator<KEY,VALUE>

java.lang.Object

org.apache.flink.api.java.operators.translation.TupleUnwrappingIterator<VALUE,KEY>

org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator<KEY,VALUE>

All Implemented Interfaces:

Serializable, Iterable<VALUE>, Iterator<VALUE>

public class HadoopTupleUnwrappingIterator<KEY,VALUE>
extends TupleUnwrappingIterator<VALUE,KEY>
implements Serializable

Wraps a Flink Tuple2 (key-value-pair) iterator into an iterator over the second (value) field.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopTupleUnwrappingIterator(TypeSerializer<KEY> keySerializer)

Method Summary

Modifier and Type	Method and Description
KEY	getCurrentKey()
boolean	hasNext()
VALUE	next()
void	remove()
void	set(Iterator<Tuple2<KEY,VALUE>> iterator) Set the Flink iterator to wrap.

Methods inherited from class org.apache.flink.api.java.operators.translation.TupleUnwrappingIterator

getLastKey, iterator

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

HadoopTupleUnwrappingIterator

public HadoopTupleUnwrappingIterator(TypeSerializer<KEY> keySerializer)

Method Detail

set

public void set(Iterator<Tuple2<KEY,VALUE>> iterator)

Set the Flink iterator to wrap.

Overrides:

set in class TupleUnwrappingIterator<VALUE,KEY>

Parameters:

iterator - The Flink iterator to wrap.

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<VALUE>

Overrides:

hasNext in class TupleUnwrappingIterator<VALUE,KEY>

next

public VALUE next()

Specified by:

next in interface Iterator<VALUE>

Overrides:

next in class TupleUnwrappingIterator<VALUE,KEY>

getCurrentKey

public KEY getCurrentKey()

remove

public void remove()

Specified by:

remove in interface Iterator<VALUE>

Overrides:

remove in class TupleUnwrappingIterator<VALUE,KEY>