org.apache.oozie.client
Class XOozieClient
java.lang.Object
org.apache.oozie.client.OozieClient
org.apache.oozie.client.XOozieClient
public class XOozieClient
- extends OozieClient
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_USER, GROUP_NAME, LIBPATH, LOG_TOKEN, RERUN_FAIL_NODES, RERUN_SKIP_NODES, USE_SYSTEM_LIBPATH, USER_NAME, WORKFLOW_NOTIFICATION_URL, WS_PROTOCOL_VERSION, WS_PROTOCOL_VERSION_0 |
Methods inherited from class org.apache.oozie.client.OozieClient |
change, createConfiguration, createConnection, 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 |
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
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.
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.path
- 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 © 2012 Apache Software Foundation. All Rights Reserved.