org.apache.hive.hcatalog.templeton

Class PigDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.LauncherDelegator

org.apache.hive.hcatalog.templeton.PigDelegator

public class PigDelegator
extends LauncherDelegator

Submit a Pig job. This is the backend of the pig 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
PigDelegator(AppConfig appConf)

Method Summary

Modifier and Type	Method and Description
EnqueueBean	run(String user, Map<String,Object> userArgs, String execute, String srcFile, List<String> pigArgs, String otherFiles, String statusdir, String callback, boolean usesHcatalog, String completedUrl, boolean enablelog, Boolean enableJobReconnect)

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

addCacheFiles, addDef, enqueueController, enqueueJob, getTempletonController, killJob, makeLauncherArgs, makeOverrideClasspath, registerJob, runTempletonControllerJob

Methods inherited from class java.lang.Object

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

Constructor Detail

PigDelegator

public PigDelegator(AppConfig appConf)

Method Detail

run

public EnqueueBean run(String user,
                       Map<String,Object> userArgs,
                       String execute,
                       String srcFile,
                       List<String> pigArgs,
                       String otherFiles,
                       String statusdir,
                       String callback,
                       boolean usesHcatalog,
                       String completedUrl,
                       boolean enablelog,
                       Boolean enableJobReconnect)
                throws NotAuthorizedException,
                       BadParam,
                       BusyException,
                       QueueException,
                       org.apache.commons.exec.ExecuteException,
                       IOException,
                       InterruptedException,
                       TooManyRequestsException

Throws:

NotAuthorizedException

BadParam

BusyException

QueueException

org.apache.commons.exec.ExecuteException

IOException

InterruptedException

TooManyRequestsException