org.apache.oozie

Class LocalOozieClient

java.lang.Object

org.apache.oozie.client.OozieClient

org.apache.oozie.LocalOozieClient

public class LocalOozieClient
extends OozieClient

Client API to submit and manage Oozie workflow jobs against an Oozie intance.

This class is thread safe.

Syntax for filter for the getJobsInfo(String) getJobsInfo(String, int, int) methods: [NAME=VALUE][;NAME=VALUE]*.

Valid filter names are:

• name: the workflow application name from the workflow definition.
• user: the user that submitted the job.
• group: the group for the job.
• status: the status of the job.

The query will do an AND among all the filter names. The query will do an OR among all the filter values for the same name. Multiple values must be specified as different name value pairs.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.client.OozieClient

OozieClient.ClientCallable<T>, OozieClient.Instrumentation, OozieClient.MapClientCallable, OozieClient.Metrics, OozieClient.SYSTEM_MODE

Field Summary

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, CHANGE_VALUE_STATUS, COORD_ACTION_NOTIFICATION_PROXY, COORD_ACTION_NOTIFICATION_URL, COORDINATOR_APP_PATH, debugMode, EXTERNAL_ID, FILTER_APPNAME, FILTER_BUNDLE, FILTER_CREATED_TIME_END, FILTER_CREATED_TIME_START, FILTER_FREQUENCY, FILTER_GROUP, FILTER_ID, FILTER_JOBID, FILTER_NAME, FILTER_NOMINAL_TIME, FILTER_SLA_APPNAME, FILTER_SLA_EVENT_STATUS, FILTER_SLA_ID, FILTER_SLA_NOMINAL_END, FILTER_SLA_NOMINAL_START, FILTER_SLA_PARENT_ID, FILTER_SLA_STATUS, FILTER_STATUS, FILTER_UNIT, FILTER_USER, GROUP_NAME, JOB_ACL, LIBPATH, LOG_TOKEN, OOZIE_SUSPEND_ON_NODES, RERUN_FAIL_NODES, RERUN_SKIP_NODES, SLA_DISABLE_ALERT, SLA_DISABLE_ALERT_COORD, SLA_DISABLE_ALERT_OLDER_THAN, SLA_ENABLE_ALERT, USE_SYSTEM_LIBPATH, USER_NAME, WORKFLOW_NOTIFICATION_PROXY, WORKFLOW_NOTIFICATION_URL, WS_PROTOCOL_VERSION, WS_PROTOCOL_VERSION_0, WS_PROTOCOL_VERSION_1

Constructor Summary

Constructors

Constructor and Description
LocalOozieClient(DagEngine dagEngine) Create a workflow client for Oozie local use.

Method Summary

Methods

Modifier and Type	Method and Description
Properties	createConfiguration() Create an empty configuration with just the OozieClient.USER_NAME set to the JVM user name and the OozieClient.GROUP_NAME set to 'other'.
String	getHeader(String name) Get the value of a set HTTP header from the workflow instance.
Iterator<String>	getHeaderNames() Return an iterator with all the header names set in the workflow instance.
String	getJobId(String externalId) Return the workflow job Id for an external Id.
WorkflowJob	getJobInfo(String jobId) Get the info of a workflow job.
List<WorkflowJob>	getJobsInfo(String filter) Return the info of the workflow jobs that match the filter.
List<WorkflowJob>	getJobsInfo(String filter, int start, int len) Return the info of the workflow jobs that match the filter.
String	getOozieUrl() Return the Oozie URL of the workflow client instance.
String	getProtocolUrl() Return the Oozie URL used by the client and server for WS communications.
void	kill(String jobId) Kill a workflow job.
void	removeHeader(String name) Remove a HTTP header from the workflow client instance.
void	reRun(String jobId, Properties conf) Rerun a workflow job.
void	resume(String jobId) Resume a workflow job.
String	run(Properties conf) Submit and start a workflow job.
void	setHeader(String name, String value) Set a HTTP header to be used in the WS requests by the workflow instance.
void	start(String jobId) Start a workflow job.
String	submit(Properties conf) Submit a workflow job.
void	suspend(String jobId) Suspend a workflow job.
void	validateWSVersion() Validate that the Oozie client and server instances are protocol compatible.

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

bulkModifyJobs, change, createConnection, createRetryableConnection, doAs, dryrun, getAvailableOozieServers, getBulkInfo, getBundleJobInfo, getBundleJobsInfo, getClientBuildVersion, getCoordActionInfo, getCoordJobInfo, getCoordJobInfo, getCoordJobInfo, getCoordJobsInfo, getDebugMode, getHeaders, getInstrumentation, getJavaSystemProperties, getJMSConnectionInfo, getJMSTopicName, getJobAuditLog, getJobDefinition, getJobErrorLog, getJobInfo, getJobLog, getJobLog, getJobLog, getMetrics, getOSEnv, getQueueDump, getRetryCount, getServerBuildVersion, getServerConfiguration, getSlaInfo, getStatus, getSystemMode, getWfsForCoordAction, getWorkflowActionInfo, ignore, kill, killJobs, listShareLib, notEmpty, notNull, pollJob, reRunBundle, reRunCoord, reRunCoord, resumeJobs, setDebugMode, setRetryCount, setSystemMode, slaChange, slaChange, slaChange, slaDisableAlert, slaDisableAlert, slaEnableAlert, slaEnableAlert, suspendJobs, updateCoord, updateCoord, updateShareLib, writeToXml

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalOozieClient

public LocalOozieClient(DagEngine dagEngine)

Create a workflow client for Oozie local use.

Parameters:

dagEngine - the dag engine instance to use.

Method Detail

getOozieUrl

public String getOozieUrl()

Return the Oozie URL of the workflow client instance.

This URL is the base URL fo the Oozie system, with not protocol versioning.

Overrides:

getOozieUrl in class OozieClient

Returns:

the Oozie URL of the workflow client instance.

getProtocolUrl

public String getProtocolUrl()
                      throws OozieClientException

Return the Oozie URL used by the client and server for WS communications.

This URL is the original URL plus the versioning element path.

Overrides:

getProtocolUrl in class OozieClient

Returns:

the Oozie URL used by the client and server for communication.

Throws:

OozieClientException - thrown in the client and the server are not protocol compatible.

validateWSVersion

public void validateWSVersion()
                       throws OozieClientException

Validate that the Oozie client and server instances are protocol compatible.

Overrides:

validateWSVersion in class OozieClient

Throws:

OozieClientException - thrown in the client and the server are not protocol compatible.

createConfiguration

public Properties createConfiguration()

Create an empty configuration with just the OozieClient.USER_NAME set to the JVM user name and the OozieClient.GROUP_NAME set to 'other'.

Overrides:

createConfiguration in class OozieClient

Returns:

an empty configuration.

setHeader

public void setHeader(String name,
             String value)

Set a HTTP header to be used in the WS requests by the workflow instance.

Overrides:

setHeader in class OozieClient

Parameters:

name - header name.

value - header value.

getHeader

public String getHeader(String name)

Get the value of a set HTTP header from the workflow instance.

Overrides:

getHeader in class OozieClient

Parameters:

name - header name.

Returns:

header value, null if not set.

removeHeader

public void removeHeader(String name)

Remove a HTTP header from the workflow client instance.

Overrides:

removeHeader in class OozieClient

Parameters:

name - header name.

getHeaderNames

public Iterator<String> getHeaderNames()

Return an iterator with all the header names set in the workflow instance.

Overrides:

getHeaderNames in class OozieClient

Returns:

header names.

submit

public String submit(Properties conf)
              throws OozieClientException

Submit a workflow job.

Overrides:

submit in class OozieClient

Parameters:

conf - job configuration.

Returns:

the job Id.

Throws:

OozieClientException - thrown if the job could not be submitted.

start

public void start(String jobId)
           throws OozieClientException

Start a workflow job.

Overrides:

start in class OozieClient

Parameters:

jobId - job Id.

Throws:

OozieClientException - thrown if the job could not be started.

run

public String run(Properties conf)
           throws OozieClientException

Submit and start a workflow job.

Overrides:

run in class OozieClient

Parameters:

conf - job configuration.

Returns:

the job Id.

Throws:

OozieClientException - thrown if the job could not be submitted.

reRun

public void reRun(String jobId,
         Properties conf)
           throws OozieClientException

Rerun a workflow job.

Overrides:

reRun in class OozieClient

Parameters:

jobId - job Id to rerun.

conf - configuration information for the rerun.

Throws:

OozieClientException - thrown if the job could not be started.

suspend

public void suspend(String jobId)
             throws OozieClientException

Suspend a workflow job.

Overrides:

suspend in class OozieClient

Parameters:

jobId - job Id.

Throws:

OozieClientException - thrown if the job could not be suspended.

resume

public void resume(String jobId)
            throws OozieClientException

Resume a workflow job.

Overrides:

resume in class OozieClient

Parameters:

jobId - job Id.

Throws:

OozieClientException - thrown if the job could not be resume.

kill

public void kill(String jobId)
          throws OozieClientException

Kill a workflow job.

Overrides:

kill in class OozieClient

Parameters:

jobId - job Id.

Throws:

OozieClientException - thrown if the job could not be killed.

getJobInfo

public WorkflowJob getJobInfo(String jobId)
                       throws OozieClientException

Get the info of a workflow job.

Overrides:

getJobInfo in class OozieClient

Parameters:

jobId - job Id.

Returns:

the job info.

Throws:

OozieClientException - thrown if the job info could not be retrieved.

getJobsInfo

public List<WorkflowJob> getJobsInfo(String filter,
                            int start,
                            int len)
                              throws OozieClientException

Return the info of the workflow jobs that match the filter.

Overrides:

getJobsInfo in class OozieClient

Parameters:

filter - job filter. Refer to the LocalOozieClient for the filter syntax.

start - jobs offset, base 1.

len - number of jobs to return.

Returns:

a list with the workflow jobs info, without node details.

Throws:

OozieClientException - thrown if the jobs info could not be retrieved.

getJobsInfo

public List<WorkflowJob> getJobsInfo(String filter)
                              throws OozieClientException

Return the info of the workflow jobs that match the filter.

It returns the first 100 jobs that match the filter.

Overrides:

getJobsInfo in class OozieClient

Parameters:

filter - job filter. Refer to the LocalOozieClient for the filter syntax.

Returns:

a list with the workflow jobs info, without node details.

Throws:

OozieClientException - thrown if the jobs info could not be retrieved.

getJobId

public String getJobId(String externalId)
                throws OozieClientException

Return the workflow job Id for an external Id.

The external Id must have provided at job creation time.

Overrides:

getJobId in class OozieClient

Parameters:

externalId - external Id given at job creation time.

Returns:

the workflow job Id for an external Id, null if none.

Throws:

OozieClientException - thrown if the operation could not be done.