[FLINK-11734] Provide HadoopReduceFunction for org.apache.hadoop.mapreduce.Reducer

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Connectors / Hadoop Compatibility
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
• Assignee: Unassigned
• Reporter: vinoyang
• Created: 23/Feb/19 09:48
• Updated: 24/Dec/21 10:39

Description

Currently, Flink only support org.apache.flink.hadoopcompatibility.mapred.Reducer in module flink-hadoop-compatibility. I think we also need to support Hadoop new Mapper API : org.apache.hadoop.mapreduce.Reducer.  We can implement a new HadoopMapFunction to wrap org.apache.hadoop.mapreduce.Reducer.