Class | Description |
---|---|
HadoopOutputCollector<KEY,VALUE> |
A Hadoop OutputCollector that wraps a Flink OutputCollector.
|
HadoopTupleUnwrappingIterator<KEY,VALUE> |
Wraps a Flink Tuple2 (key-value-pair) iterator into an iterator over the second (value) field.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.