Package org.apache.flink.hadoopcompatibility.mapred
-
Class Summary Class Description HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.HadoopReducerWrappedFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> This wrapper maps a Hadoop Reducer (mapred API) to a Flink window function.