This project has retired. For details please refer to its Attic page.

org.apache.oozie.client
Class XOozieClient

java.lang.Object
  org.apache.oozie.client.OozieClient
      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	IS_PROXY_SUBMISSION
static String	JT
static String	JT_PRINCIPAL
static String	NN
static String	NN_PRINCIPAL
static String	PIG_OPTIONS
static String	PIG_SCRIPT

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_FREQUENCY, FILTER_GROUP, FILTER_ID, FILTER_NAME, FILTER_STATUS, FILTER_UNIT, FILTER_USER, GROUP_NAME, JOB_ACL, LIBPATH, LOG_TOKEN, RERUN_FAIL_NODES, RERUN_SKIP_NODES, USE_SYSTEM_LIBPATH, USER_NAME, WORKFLOW_NOTIFICATION_URL, WS_PROTOCOL_VERSION, WS_PROTOCOL_VERSION_0

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) Submit a Pig job via HTTP.

Methods inherited from class org.apache.oozie.client.OozieClient

change, createConfiguration, createConnection, doAs, dryrun, getBundleJobInfo, getBundleJobsInfo, getClientBuildVersion, getCoordActionInfo, getCoordJobInfo, getCoordJobInfo, getCoordJobsInfo, getDebugMode, getHeader, getHeaderNames, getHeaders, 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

NN

public static final String NN

See Also:

Constant Field Values

JT_PRINCIPAL

public static final String JT_PRINCIPAL

See Also:

Constant Field Values

NN_PRINCIPAL

public static final String NN_PRINCIPAL

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

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

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

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

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.