org.apache.oozie.client
Class XOozieClient

java.lang.Object
  extended by org.apache.oozie.client.OozieClient
      extended by org.apache.oozie.client.XOozieClient
Direct Known Subclasses:
AuthOozieClient

public class XOozieClient
extends OozieClient


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.oozie.client.OozieClient
OozieClient.ClientCallable<T>, OozieClient.SYSTEM_MODE
 
Field Summary
static String ARCHIVES
           
static String FILES
           
static String HIVE_OPTIONS
           
static String HIVE_SCRIPT
           
static String HIVE_SCRIPT_PARAMS
           
static String IS_PROXY_SUBMISSION
           
static String JT
           
static String JT_2
           
static String JT_PRINCIPAL
          Deprecated. 
static String NN
           
static String NN_2
           
static String NN_PRINCIPAL
          Deprecated. 
static String PIG_OPTIONS
           
static String PIG_SCRIPT
           
static String PIG_SCRIPT_PARAMS
           
 
Fields inherited from class org.apache.oozie.client.OozieClient
ACTION_MAX_RETRIES, ACTION_NOTIFICATION_URL, ACTION_RETRY_INTERVAL, APP_PATH, BUNDLE_APP_PATH, BUNDLE_ID, CHANGE_VALUE_CONCURRENCY, CHANGE_VALUE_ENDTIME, CHANGE_VALUE_PAUSETIME, COORD_ACTION_NOTIFICATION_URL, COORDINATOR_APP_PATH, debugMode, EXTERNAL_ID, FILTER_APPNAME, FILTER_FREQUENCY, FILTER_GROUP, FILTER_ID, FILTER_JOBID, FILTER_NAME, FILTER_SLA_APPNAME, FILTER_SLA_ID, FILTER_SLA_NOMINAL_END, FILTER_SLA_NOMINAL_START, FILTER_SLA_PARENT_ID, FILTER_STATUS, FILTER_UNIT, FILTER_USER, GROUP_NAME, JOB_ACL, LIBPATH, LOG_TOKEN, OOZIE_SUSPEND_ON_NODES, RERUN_FAIL_NODES, RERUN_SKIP_NODES, USE_SYSTEM_LIBPATH, USER_NAME, WORKFLOW_NOTIFICATION_URL, WS_PROTOCOL_VERSION, WS_PROTOCOL_VERSION_0, WS_PROTOCOL_VERSION_1
 
Constructor Summary
protected XOozieClient()
           
  XOozieClient(String oozieUrl)
          Create an eXtended Workflow client instance.
 
Method Summary
 void addArchive(Properties conf, String file)
          The equivalent to tag in oozie's workflow xml.
 void addFile(Properties conf, String file)
          The equivalent to tag in oozie's workflow xml.
 void setLib(Properties conf, String pathStr)
          set LIBPATH for HTTP submission job.
 String submitMapReduce(Properties conf)
          Submit a Map/Reduce job via HTTP.
 String submitPig(Properties conf, String pigScriptFile, String[] pigArgs)
          Deprecated. 
 String submitScriptLanguage(Properties conf, String scriptFile, String[] args, String jobType)
          Submit a Pig or Hive job via HTTP.
 String submitScriptLanguage(Properties conf, String scriptFile, String[] args, String[] params, String jobType)
          Submit a Pig or Hive job via HTTP.
 
Methods inherited from class org.apache.oozie.client.OozieClient
change, createConfiguration, createConnection, doAs, dryrun, getBulkInfo, getBundleJobInfo, getBundleJobsInfo, getClientBuildVersion, getCoordActionInfo, getCoordJobInfo, getCoordJobInfo, getCoordJobsInfo, getDebugMode, getHeader, getHeaderNames, getHeaders, getJMSConnectionInfo, getJMSTopicName, getJobDefinition, getJobId, getJobInfo, getJobInfo, getJobLog, getJobLog, getJobsInfo, getJobsInfo, getOozieUrl, getProtocolUrl, getQueueDump, getServerBuildVersion, getSlaInfo, getSystemMode, getWorkflowActionInfo, kill, notEmpty, notNull, removeHeader, reRun, reRunBundle, reRunCoord, resume, run, setDebugMode, setHeader, setSystemMode, start, submit, suspend, validateWSVersion, writeToXml
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

JT

public static final String JT
See Also:
Constant Field Values

JT_2

public static final String JT_2
See Also:
Constant Field Values

NN

public static final String NN
See Also:
Constant Field Values

NN_2

public static final String NN_2
See Also:
Constant Field Values

JT_PRINCIPAL

@Deprecated
public static final String JT_PRINCIPAL
Deprecated. 
See Also:
Constant Field Values

NN_PRINCIPAL

@Deprecated
public static final String NN_PRINCIPAL
Deprecated. 
See Also:
Constant Field Values

PIG_SCRIPT

public static final String PIG_SCRIPT
See Also:
Constant Field Values

PIG_OPTIONS

public static final String PIG_OPTIONS
See Also:
Constant Field Values

PIG_SCRIPT_PARAMS

public static final String PIG_SCRIPT_PARAMS
See Also:
Constant Field Values

HIVE_SCRIPT

public static final String HIVE_SCRIPT
See Also:
Constant Field Values

HIVE_OPTIONS

public static final String HIVE_OPTIONS
See Also:
Constant Field Values

HIVE_SCRIPT_PARAMS

public static final String HIVE_SCRIPT_PARAMS
See Also:
Constant Field Values

FILES

public static final String FILES
See Also:
Constant Field Values

ARCHIVES

public static final String ARCHIVES
See Also:
Constant Field Values

IS_PROXY_SUBMISSION

public static final String IS_PROXY_SUBMISSION
See Also:
Constant Field Values
Constructor Detail

XOozieClient

protected XOozieClient()

XOozieClient

public XOozieClient(String oozieUrl)
Create an eXtended Workflow client instance.

Parameters:
oozieUrl - URL of the Oozie instance it will interact with.
Method Detail

submitPig

@Deprecated
public String submitPig(Properties conf,
                                   String pigScriptFile,
                                   String[] pigArgs)
                 throws IOException,
                        OozieClientException
Deprecated. 

Submit a Pig job via HTTP.

Parameters:
conf - job configuration.
pigScriptFile - pig script file.
pigArgs - pig arguments string.
Returns:
the job Id.
Throws:
OozieClientException - thrown if the job could not be submitted.
IOException

submitScriptLanguage

public String submitScriptLanguage(Properties conf,
                                   String scriptFile,
                                   String[] args,
                                   String jobType)
                            throws IOException,
                                   OozieClientException
Submit a Pig or Hive job via HTTP.

Parameters:
conf - job configuration.
scriptFile - script file.
args - arguments string.
Returns:
the job Id.
Throws:
OozieClientException - thrown if the job could not be submitted.
IOException

submitScriptLanguage

public String submitScriptLanguage(Properties conf,
                                   String scriptFile,
                                   String[] args,
                                   String[] params,
                                   String jobType)
                            throws IOException,
                                   OozieClientException
Submit a Pig or Hive job via HTTP.

Parameters:
conf - job configuration.
scriptFile - script file.
args - arguments string.
params - parameters string.
Returns:
the job Id.
Throws:
OozieClientException - thrown if the job could not be submitted.
IOException

submitMapReduce

public String submitMapReduce(Properties conf)
                       throws OozieClientException
Submit a Map/Reduce job via HTTP.

Parameters:
conf - job configuration.
Returns:
the job Id.
Throws:
OozieClientException - thrown if the job could not be submitted.

setLib

public void setLib(Properties conf,
                   String pathStr)
set LIBPATH for HTTP submission job.

Parameters:
conf - Configuration object.
pathStr - lib HDFS path.

addFile

public void addFile(Properties conf,
                    String file)
The equivalent to tag in oozie's workflow xml.

Parameters:
conf - Configuration object.
file - file HDFS path. A "#..." symbolic string can be appended to the path to specify symbolic link name. For example, "/user/oozie/parameter_file#myparams". If no "#..." is specified, file name will be used as symbolic link name.

addArchive

public void addArchive(Properties conf,
                       String file)
The equivalent to tag in oozie's workflow xml.

Parameters:
conf - Configuration object.
file - file HDFS path. A "#..." symbolic string can be appended to the path to specify symbolic link name. For example, "/user/oozie/udf1.jar#my.jar". If no "#..." is specified, file name will be used as symbolic link name.


Copyright © 2013 Apache Software Foundation. All Rights Reserved.