org.apache.oozie.action.hadoop
Class SqoopActionExecutor

java.lang.Object
  org.apache.oozie.action.ActionExecutor
      org.apache.oozie.action.hadoop.JavaActionExecutor
          org.apache.oozie.action.hadoop.SqoopActionExecutor

public class SqoopActionExecutor
extends JavaActionExecutor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.action.ActionExecutor

ActionExecutor.Context

Field Summary

Fields inherited from class org.apache.oozie.action.hadoop.JavaActionExecutor

log, MAX_EXTERNAL_STATS_SIZE, MAX_EXTERNAL_STATS_SIZE_DEFAULT, OOZIE_COMMON_LIBDIR

Fields inherited from class org.apache.oozie.action.ActionExecutor

CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, RETRY_INTERVAL

Constructor Summary

SqoopActionExecutor()

Method Summary

protected boolean	getCaptureOutput(org.apache.oozie.client.WorkflowAction action)
protected List<Class>	getLauncherClasses()
protected String	getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf, org.jdom.Element actionXml)
protected String	getShareLibPostFix(ActionExecutor.Context context, org.jdom.Element actionXml) Return the sharelib postfix for the action.

Methods inherited from class org.apache.oozie.action.hadoop.JavaActionExecutor

addShareLib, check, createBaseHadoopConf, createJobClient, end, getActionCredentialsProperties, getActionData, getActionFileSystem, getActionFileSystem, getCredProperties, getLauncherJarName, getMaxExternalStatsSize, initActionType, isCompleted, kill, prepareActionDir, setCredentialPropertyToActionConf, setCredentialTokens, start, submitLauncher

Methods inherited from class org.apache.oozie.action.ActionExecutor

convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getType, registerError, resetInitInfo, setMaxRetries, setRetryInterval

Methods inherited from class java.lang.Object

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

Constructor Detail

SqoopActionExecutor

public SqoopActionExecutor()

Method Detail

getLauncherClasses

protected List<Class> getLauncherClasses()

Overrides:

getLauncherClasses in class JavaActionExecutor

getLauncherMain

protected String getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf,
                                 org.jdom.Element actionXml)

Overrides:

getLauncherMain in class JavaActionExecutor

getCaptureOutput

protected boolean getCaptureOutput(org.apache.oozie.client.WorkflowAction action)
                            throws org.jdom.JDOMException

Overrides:

getCaptureOutput in class JavaActionExecutor

Throws:

org.jdom.JDOMException

getShareLibPostFix

protected String getShareLibPostFix(ActionExecutor.Context context,
                                    org.jdom.Element actionXml)

Return the sharelib postfix for the action.

Overrides:

getShareLibPostFix in class JavaActionExecutor

Parameters:

context - executor context.

actionXml - the action XML.

Returns:

the action sharelib post fix, this implementation returns hive.