Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.conf.Configuration |
getHadoopConfiguration()
Returns a new Hadoop Configuration object using the path to the hadoop conf configured
in the main configuration (flink-conf.yaml).
|
static boolean |
hasHDFSDelegationToken()
Indicates whether the current user has an HDFS delegation token.
|
static org.apache.hadoop.mapred.JobContext |
instantiateJobContext(org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.mapred.JobID jobId) |
static org.apache.hadoop.mapred.TaskAttemptContext |
instantiateTaskAttemptContext(org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.mapred.TaskAttemptID taskAttemptID) |
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 org.apache.hadoop.mapred.JobContext instantiateJobContext(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.JobID jobId) throws Exception
Exception
public static org.apache.hadoop.mapred.TaskAttemptContext instantiateTaskAttemptContext(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.TaskAttemptID taskAttemptID) throws Exception
Exception
public static org.apache.hadoop.conf.Configuration getHadoopConfiguration()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.