Uses of Class
org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat

Packages that use HadoopInputFormat

Package	Description
org.apache.flink.hadoopcompatibility

Uses of HadoopInputFormat in org.apache.flink.hadoopcompatibility

Methods in org.apache.flink.hadoopcompatibility that return HadoopInputFormat

Modifier and Type	Method	Description
static <K,V> HadoopInputFormat<K,V>	HadoopInputs.createHadoopInput(org.apache.hadoop.mapred.InputFormat<K,V> mapredInputFormat, Class<K> key, Class<V> value, org.apache.hadoop.mapred.JobConf job)	Creates a Flink InputFormat that wraps the given Hadoop InputFormat.
static <K,V> HadoopInputFormat<K,V>	HadoopInputs.readHadoopFile(org.apache.hadoop.mapred.FileInputFormat<K,V> mapredInputFormat, Class<K> key, Class<V> value, String inputPath)	Creates a Flink InputFormat that wraps the given Hadoop FileInputFormat.
static <K,V> HadoopInputFormat<K,V>	HadoopInputs.readHadoopFile(org.apache.hadoop.mapred.FileInputFormat<K,V> mapredInputFormat, Class<K> key, Class<V> value, String inputPath, org.apache.hadoop.mapred.JobConf job)	Creates a Flink InputFormat that wraps the given Hadoop FileInputFormat.
static <K,V> HadoopInputFormat<K,V>	HadoopInputs.readSequenceFile(Class<K> key, Class<V> value, String inputPath)	Creates a Flink InputFormat to read a Hadoop sequence file for the given key and value classes.