Package org.apache.flink.api.java.hadoop.mapreduce
-
Class Summary Class Description HadoopInputFormat<K,V> InputFormat implementation allowing to use Hadoop (mapreduce) InputFormats with Flink.HadoopInputFormatBase<K,V,T> Base class shared between the Java and Scala API of Flink.HadoopOutputFormat<K,V> OutputFormat implementation allowing to use Hadoop (mapreduce) OutputFormats with Flink.HadoopOutputFormatBase<K,V,T> Base class shared between the Java and Scala API of Flink.