public class HadoopTupleUnwrappingIterator<KEY,VALUE> extends TupleUnwrappingIterator<VALUE,KEY> implements Serializable
Constructor and Description |
---|
HadoopTupleUnwrappingIterator(TypeSerializer<KEY> keySerializer) |
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.
|
getLastKey, iterator
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
forEach, spliterator
public HadoopTupleUnwrappingIterator(TypeSerializer<KEY> keySerializer)
public void set(Iterator<Tuple2<KEY,VALUE>> iterator)
set
in class TupleUnwrappingIterator<VALUE,KEY>
iterator
- The Flink iterator to wrap.public boolean hasNext()
public VALUE next()
public KEY getCurrentKey()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.