org.apache.hive.hcatalog.templeton

Class SqoopDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.LauncherDelegator

org.apache.hive.hcatalog.templeton.SqoopDelegator

public class SqoopDelegator
extends LauncherDelegator

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

Method Summary

Methods

Modifier and Type	Method and Description
EnqueueBean	run(String user, Map<String,Object> userArgs, String command, String optionsFile, String otherFiles, String statusdir, String callback, String completedUrl, boolean enablelog, Boolean enableJobReconnect, String libdir)

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

SqoopDelegator

public SqoopDelegator(AppConfig appConf)

Method Detail

run

public EnqueueBean run(String user,
              Map<String,Object> userArgs,
              String command,
              String optionsFile,
              String otherFiles,
              String statusdir,
              String callback,
              String completedUrl,
              boolean enablelog,
              Boolean enableJobReconnect,
              String libdir)
                throws NotAuthorizedException,
                       BadParam,
                       BusyException,
                       QueueException,
                       IOException,
                       InterruptedException

Throws:

NotAuthorizedException

BadParam

BusyException

QueueException

IOException

InterruptedException