org.apache.hive.hcatalog.templeton

Class StreamingDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.LauncherDelegator

org.apache.hive.hcatalog.templeton.StreamingDelegator

public class StreamingDelegator
extends LauncherDelegator

Submit a streaming job to the MapReduce queue. Really just a front end to the JarDelegator. This is the backend of the mapreduce/streaming web service.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hive.hcatalog.templeton.LauncherDelegator

LauncherDelegator.JobType

Field Summary

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

runAs

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

appConf

Constructor Summary

Constructors

Constructor and Description
StreamingDelegator(AppConfig appConf)

Method Summary

Modifier and Type

Method and Description

EnqueueBean

run(java.lang.String user, java.util.Map<java.lang.String,java.lang.Object> userArgs, java.util.List<java.lang.String> inputs, java.lang.String output, java.lang.String mapper, java.lang.String reducer, java.lang.String combiner, java.util.List<java.lang.String> fileList, java.lang.String files, java.util.List<java.lang.String> defines, java.util.List<java.lang.String> cmdenvs, java.util.List<java.lang.String> jarArgs, java.lang.String statusdir, java.lang.String callback, java.lang.String completedUrl, boolean enableLog, LauncherDelegator.JobType jobType)

Methods inherited from class org.apache.hive.hcatalog.templeton.LauncherDelegator

addCacheFiles, addDef, enqueueController, makeLauncherArgs, makeOverrideClasspath, registerJob

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingDelegator

public StreamingDelegator(AppConfig appConf)

Method Detail

run

public EnqueueBean run(java.lang.String user,
                       java.util.Map<java.lang.String,java.lang.Object> userArgs,
                       java.util.List<java.lang.String> inputs,
                       java.lang.String output,
                       java.lang.String mapper,
                       java.lang.String reducer,
                       java.lang.String combiner,
                       java.util.List<java.lang.String> fileList,
                       java.lang.String files,
                       java.util.List<java.lang.String> defines,
                       java.util.List<java.lang.String> cmdenvs,
                       java.util.List<java.lang.String> jarArgs,
                       java.lang.String statusdir,
                       java.lang.String callback,
                       java.lang.String completedUrl,
                       boolean enableLog,
                       LauncherDelegator.JobType jobType)
                throws NotAuthorizedException,
                       BadParam,
                       BusyException,
                       QueueException,
                       ExecuteException,
                       java.io.IOException,
                       java.lang.InterruptedException

Throws:

NotAuthorizedException

BadParam

BusyException

QueueException

ExecuteException

java.io.IOException

java.lang.InterruptedException