Modifier and Type | Method and Description |
---|---|
static Configuration |
getHadoopConfiguration(Configuration flinkConfiguration)
Returns a new Hadoop Configuration object using the path to the hadoop conf configured
in the main configuration (flink-conf.yaml).
|
static void |
mergeHadoopConf(org.apache.hadoop.mapred.JobConf jobConf)
Merge HadoopConfiguration into JobConf.
|
public static void mergeHadoopConf(org.apache.hadoop.mapred.JobConf jobConf)
public static Configuration getHadoopConfiguration(Configuration flinkConfiguration)
flinkConfiguration
- Flink configuration objectCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.