static <K,V> HadoopInputFormat<K,V> |
HadoopInputs.createHadoopInput(org.apache.hadoop.mapreduce.InputFormat<K,V> mapreduceInputFormat,
Class<K> key,
Class<V> value,
org.apache.hadoop.mapreduce.Job job) |
Creates a Flink InputFormat that wraps the given Hadoop InputFormat.
|
static <K,V> HadoopInputFormat<K,V> |
HadoopInputs.readHadoopFile(org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V> mapreduceInputFormat,
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.mapreduce.lib.input.FileInputFormat<K,V> mapreduceInputFormat,
Class<K> key,
Class<V> value,
String inputPath,
org.apache.hadoop.mapreduce.Job job) |
Creates a Flink InputFormat that wraps the given Hadoop FileInputFormat.
|