Package | Description |
---|---|
org.apache.flink.hadoopcompatibility.scala |
Modifier and Type | Method and 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,
TypeInformation<scala.Tuple2<K,V>> tpe)
Creates a Flink
InputFormat that wraps the given Hadoop
InputFormat . |
<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,
TypeInformation<scala.Tuple2<K,V>> tpe)
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,
org.apache.hadoop.mapred.JobConf job,
TypeInformation<scala.Tuple2<K,V>> tpe)
Creates a Flink
InputFormat that wraps the given Hadoop
FileInputFormat . |
<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,
TypeInformation<scala.Tuple2<K,V>> tpe)
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,
TypeInformation<scala.Tuple2<K,V>> tpe)
Creates a Flink
InputFormat that wraps the given Hadoop
FileInputFormat . |
<K,V> HadoopInputFormat<K,V> |
HadoopInputs$.readHadoopFile(org.apache.hadoop.mapred.FileInputFormat<K,V> mapredInputFormat,
Class<K> key,
Class<V> value,
String inputPath,
TypeInformation<scala.Tuple2<K,V>> tpe)
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,
TypeInformation<scala.Tuple2<K,V>> tpe)
Creates a Flink
InputFormat that reads a Hadoop sequence
file with the given key and value classes. |
<K,V> HadoopInputFormat<K,V> |
HadoopInputs$.readSequenceFile(Class<K> key,
Class<V> value,
String inputPath,
TypeInformation<scala.Tuple2<K,V>> tpe)
Creates a Flink
InputFormat that reads a Hadoop sequence
file with the given key and value classes. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.