Class | Description |
---|---|
HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> |
This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
|
HadoopReduceCombineFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> |
This wrapper maps a Hadoop Reducer and Combiner (mapred API) to a combinable Flink GroupReduceFunction.
|
HadoopReduceFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> |
This wrapper maps a Hadoop Reducer (mapred API) to a non-combinable Flink GroupReduceFunction.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.