Package org.apache.flink.hadoopcompatibility.mapred.wrapper
-
Class Summary 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.