HadoopTupleUnwrappingIterator (Flink : Connectors : Hadoop compatibility 2.1.1-cp1 API)

java.lang.Object
- org.apache.flink.api.common.operators.util.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 org.apache.flink.api.common.operators.util.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 Description

HadoopTupleUnwrappingIterator(org.apache.flink.api.common.typeutils.TypeSerializer<KEY> keySerializer)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`KEY`	`getCurrentKey()`
`boolean`	`hasNext()`
`VALUE`	`next()`
`void`	`remove()`
`void`	`set(Iterator<org.apache.flink.api.java.tuple.Tuple2<KEY,VALUE>> iterator)`	Set the Flink iterator to wrap.

Methods inherited from class org.apache.flink.api.common.operators.util.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.lang.Iterable
forEach, spliterator

Methods inherited from interface java.util.Iterator
forEachRemaining

- Constructor Detail
  - HadoopTupleUnwrappingIterator
```
public HadoopTupleUnwrappingIterator(org.apache.flink.api.common.typeutils.TypeSerializer<KEY> keySerializer)
```
- Method Detail
  - set
```
public void set(Iterator<org.apache.flink.api.java.tuple.Tuple2<KEY,VALUE>> iterator)
```
    Set the Flink iterator to wrap.
    
    Overrides:
    
    set in class org.apache.flink.api.common.operators.util.TupleUnwrappingIterator<VALUE,KEY>
    
    Parameters:
    
    iterator - The Flink iterator to wrap.
  - hasNext
```
public boolean hasNext()
```
    Specified by:
    
    hasNext in interface Iterator<KEY>
    
    Overrides:
    
    hasNext in class org.apache.flink.api.common.operators.util.TupleUnwrappingIterator<VALUE,KEY>
  - next
```
public VALUE next()
```
    Specified by:
    
    next in interface Iterator<KEY>
    
    Overrides:
    
    next in class org.apache.flink.api.common.operators.util.TupleUnwrappingIterator<VALUE,KEY>
  - getCurrentKey
```
public KEY getCurrentKey()
```
  - remove
```
public void remove()
```
    Specified by:
    
    remove in interface Iterator<KEY>
    
    Overrides:
    
    remove in class org.apache.flink.api.common.operators.util.TupleUnwrappingIterator<VALUE,KEY>