org.apache.hive.hcatalog.templeton

Class LauncherDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.LauncherDelegator

Direct Known Subclasses:

HcatDelegator, HiveDelegator, JarDelegator, PigDelegator, SqoopDelegator, StreamingDelegator

public class LauncherDelegator
extends TempletonDelegator

The helper class for all the Templeton delegator classes that launch child jobs.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LauncherDelegator.JobType

Field Summary

Fields

Modifier and Type	Field and Description
protected String	runAs

Fields inherited from class org.apache.hive.hcatalog.templeton.TempletonDelegator

appConf, ARCHIVES, FILES

Constructor Summary

Constructors

Constructor and Description
LauncherDelegator(AppConfig appConf)

Method Summary

Methods

Modifier and Type	Method and Description
static void	addCacheFiles(List<String> args, AppConfig appConf) Add files to the Distributed Cache for the controller job.
static void	addDef(List<String> args, String name, String val) Add a Hadoop command line definition to args if the value is not null.
EnqueueBean	enqueueController(String user, Map<String,Object> userArgs, String callback, List<String> args) Enqueue the TempletonControllerJob directly calling doAs.
List<String>	makeLauncherArgs(AppConfig appConf, String statusdir, String completedUrl, List<String> copyFiles, boolean enablelog, Boolean enableJobReconnect, LauncherDelegator.JobType jobType)
static String	makeOverrideClasspath(AppConfig appConf) Create the override classpath, which will be added to HADOOP_CLASSPATH at runtime by the controller job.
void	registerJob(String id, String user, String callback, Map<String,Object> userArgs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

runAs

protected String runAs

Constructor Detail

LauncherDelegator

public LauncherDelegator(AppConfig appConf)

Method Detail

registerJob

public void registerJob(String id,
               String user,
               String callback,
               Map<String,Object> userArgs)
                 throws IOException

Throws:

IOException

enqueueController

public EnqueueBean enqueueController(String user,
                            Map<String,Object> userArgs,
                            String callback,
                            List<String> args)
                              throws NotAuthorizedException,
                                     BusyException,
                                     IOException,
                                     QueueException

Enqueue the TempletonControllerJob directly calling doAs.

Throws:

NotAuthorizedException

BusyException

IOException

QueueException

makeLauncherArgs

public List<String> makeLauncherArgs(AppConfig appConf,
                            String statusdir,
                            String completedUrl,
                            List<String> copyFiles,
                            boolean enablelog,
                            Boolean enableJobReconnect,
                            LauncherDelegator.JobType jobType)

addCacheFiles

public static void addCacheFiles(List<String> args,
                 AppConfig appConf)

Add files to the Distributed Cache for the controller job.

makeOverrideClasspath

public static String makeOverrideClasspath(AppConfig appConf)

Create the override classpath, which will be added to HADOOP_CLASSPATH at runtime by the controller job.

addDef

public static void addDef(List<String> args,
          String name,
          String val)

Add a Hadoop command line definition to args if the value is not null.