@InterfaceAudience.Private public class TempletonControllerJob extends org.apache.hadoop.conf.Configured implements org.apache.hadoop.util.Tool, JobSubmissionConstants
JobSubmissionConstants.PigConstants, JobSubmissionConstants.Sqoop
COPY_NAME, ENABLE_JOB_RECONNECT, ENABLE_LOG, EXIT_FNAME, HADOOP_CLASSPATH, HADOOP_CLASSPATH_EXTRAS, JAR_ARGS_NAME, JOB_TYPE, KEEP_ALIVE_MSEC, MAPREDUCE_JOB_TAGS, MAPREDUCE_JOB_TAGS_ARG_PLACEHOLDER, OVERRIDE_CLASSPATH, POLL_JOBPROGRESS_MSEC, STATUSDIR_NAME, STDERR_FNAME, STDOUT_FNAME, TEMPLETON_JOB_LAUNCH_TIME_NAME, TOKEN_FILE_ARG_PLACEHOLDER, TOKEN_FILE_ARG_PLACEHOLDER_TEZ, WATCHER_TIMEOUT_SECS
Constructor and Description |
---|
TempletonControllerJob(boolean secureMetastoreAccess,
AppConfig conf) |
Modifier and Type | Method and Description |
---|---|
String |
getSubmittedId() |
int |
run(String[] args)
Enqueue the job and print out the job id for later collection.
|
public TempletonControllerJob(boolean secureMetastoreAccess, AppConfig conf)
secureMetastoreAccess
- - if true, a delegation token will be created
and added to the jobpublic String getSubmittedId()
public int run(String[] args) throws IOException, InterruptedException, ClassNotFoundException, org.apache.thrift.TException
run
in interface org.apache.hadoop.util.Tool
IOException
InterruptedException
ClassNotFoundException
org.apache.thrift.TException
CompleteDelegator
Copyright © 2019 The Apache Software Foundation. All rights reserved.