|
Rename Parameter mapredInputFormat : InputFormat<K,V> to mapreduceInputFormat : InputFormat<K,V> in method public createHadoopInput(mapreduceInputFormat InputFormat<K,V>, key Class<K>, value Class<V>, job Job) : DataSource<Tuple2<K,V>> in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Rename Parameter mapredInputFormat : FileInputFormat<K,V> to mapreduceInputFormat : FileInputFormat<K,V> in method public readHadoopFile(mapreduceInputFormat FileInputFormat<K,V>, key Class<K>, value Class<V>, inputPath String) : DataSource<Tuple2<K,V>> in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Rename Parameter mapredInputFormat : FileInputFormat<K,V> to mapreduceInputFormat : FileInputFormat<K,V> in method public readHadoopFile(mapreduceInputFormat FileInputFormat<K,V>, key Class<K>, value Class<V>, inputPath String, job Job) : DataSource<Tuple2<K,V>> in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |