org.apache.oozie.command.wf
Class SubmitPigCommand

java.lang.Object
  org.apache.oozie.command.Command<T,WorkflowStore>
      org.apache.oozie.command.wf.WorkflowCommand<String>
          org.apache.oozie.command.wf.SubmitHttpCommand
              org.apache.oozie.command.wf.SubmitPigCommand

All Implemented Interfaces:

Callable<String>, XCallable<String>

public class SubmitPigCommand
extends SubmitHttpCommand

Field Summary

Fields inherited from class org.apache.oozie.command.wf.SubmitHttpCommand

MANDATORY_OOZIE_CONFS, OPTIONAL_OOZIE_CONFS, USE_SYSTEM_LIBPATH_FOR_MR_PIG_JOBS

Fields inherited from class org.apache.oozie.command.Command

dryrun, instrumentation, LOCK_FAILURE_REQUEUE_INTERVAL

Constructor Summary

SubmitPigCommand(org.apache.hadoop.conf.Configuration conf, String authToken)

Method Summary

protected String

getWorkflowXml(org.apache.hadoop.conf.Configuration conf) Generate workflow xml from conf object

Methods inherited from class org.apache.oozie.command.wf.SubmitHttpCommand

call

Methods inherited from class org.apache.oozie.command.wf.WorkflowCommand

getStoreClass

Methods inherited from class org.apache.oozie.command.Command

call, execute, getCreatedTime, getInstrumentation, getKey, getName, getPriority, getType, incrCommandCounter, incrJobCounter, incrJobCounter, lock, logQueueCallableFalse, queueCallable, queueCallable, queueCallable, queueCallableForException, resetLogInfoAction, resetLogInfoWorkflow, setLogInfo, setLogInfo, setLogInfo, setLogInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SubmitPigCommand

public SubmitPigCommand(org.apache.hadoop.conf.Configuration conf,
                        String authToken)

Method Detail

getWorkflowXml

protected String getWorkflowXml(org.apache.hadoop.conf.Configuration conf)

Description copied from class: SubmitHttpCommand

Generate workflow xml from conf object

Specified by:

getWorkflowXml in class SubmitHttpCommand

Parameters:

conf - the configuration object

Returns:

workflow xml def string representation