Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.conf.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.
|
static String[] |
possibleHadoopConfPaths(Configuration flinkConfiguration)
Get possible Hadoop conf dir paths, based on environment variables and flink configuration.
|
public static void mergeHadoopConf(org.apache.hadoop.mapred.JobConf jobConf)
public static org.apache.hadoop.conf.Configuration getHadoopConfiguration(Configuration flinkConfiguration)
flinkConfiguration
- Flink configuration objectpublic static String[] possibleHadoopConfPaths(Configuration flinkConfiguration)
flinkConfiguration
- The flink configuration that may contain the path to Hadoop conf
dir.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.