public class LauncherDelegator extends TempletonDelegator
Modifier and Type | Class and Description |
---|---|
static class |
LauncherDelegator.JobType |
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
runAs |
appConf
Constructor and Description |
---|
LauncherDelegator(AppConfig appConf) |
Modifier and Type | Method and Description |
---|---|
static void |
addCacheFiles(java.util.List<java.lang.String> args,
AppConfig appConf)
Add files to the Distributed Cache for the controller job.
|
static void |
addDef(java.util.List<java.lang.String> args,
java.lang.String name,
java.lang.String val)
Add a Hadoop command line definition to args if the value is
not null.
|
EnqueueBean |
enqueueController(java.lang.String user,
java.util.Map<java.lang.String,java.lang.Object> userArgs,
java.lang.String callback,
java.util.List<java.lang.String> args)
Enqueue the TempletonControllerJob directly calling doAs.
|
java.util.List<java.lang.String> |
makeLauncherArgs(AppConfig appConf,
java.lang.String statusdir,
java.lang.String completedUrl,
java.util.List<java.lang.String> copyFiles,
boolean enablelog,
LauncherDelegator.JobType jobType) |
static java.lang.String |
makeOverrideClasspath(AppConfig appConf)
Create the override classpath, which will be added to
HADOOP_CLASSPATH at runtime by the controller job.
|
void |
registerJob(java.lang.String id,
java.lang.String user,
java.lang.String callback,
java.util.Map<java.lang.String,java.lang.Object> userArgs) |
public LauncherDelegator(AppConfig appConf)
public void registerJob(java.lang.String id, java.lang.String user, java.lang.String callback, java.util.Map<java.lang.String,java.lang.Object> userArgs) throws java.io.IOException
java.io.IOException
public EnqueueBean enqueueController(java.lang.String user, java.util.Map<java.lang.String,java.lang.Object> userArgs, java.lang.String callback, java.util.List<java.lang.String> args) throws NotAuthorizedException, BusyException, ExecuteException, java.io.IOException, QueueException
NotAuthorizedException
BusyException
ExecuteException
java.io.IOException
QueueException
public java.util.List<java.lang.String> makeLauncherArgs(AppConfig appConf, java.lang.String statusdir, java.lang.String completedUrl, java.util.List<java.lang.String> copyFiles, boolean enablelog, LauncherDelegator.JobType jobType)
public static void addCacheFiles(java.util.List<java.lang.String> args, AppConfig appConf)
public static java.lang.String makeOverrideClasspath(AppConfig appConf)
public static void addDef(java.util.List<java.lang.String> args, java.lang.String name, java.lang.String val)
Copyright © 2012 The Apache Software Foundation