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, ARCHIVES, FILES

Constructor Summary

Constructors

Constructor and Description
StreamingDelegator(AppConfig appConf)

Method Summary

Methods

Modifier and Type	Method and Description
EnqueueBean	run(String user, Map<String,Object> userArgs, List<String> inputs, String inputreader, String output, String mapper, String reducer, String combiner, List<String> fileList, String files, List<String> defines, List<String> cmdenvs, List<String> jarArgs, String statusdir, String callback, String completedUrl, boolean enableLog, Boolean enableJobReconnect, 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(String user,
              Map<String,Object> userArgs,
              List<String> inputs,
              String inputreader,
              String output,
              String mapper,
              String reducer,
              String combiner,
              List<String> fileList,
              String files,
              List<String> defines,
              List<String> cmdenvs,
              List<String> jarArgs,
              String statusdir,
              String callback,
              String completedUrl,
              boolean enableLog,
              Boolean enableJobReconnect,
              LauncherDelegator.JobType jobType)
                throws NotAuthorizedException,
                       BadParam,
                       BusyException,
                       QueueException,
                       org.apache.commons.exec.ExecuteException,
                       IOException,
                       InterruptedException

Throws:

NotAuthorizedException

BadParam

BusyException

QueueException

org.apache.commons.exec.ExecuteException

IOException

InterruptedException