org.apache.oozie

Class LocalOozieClientCoord

java.lang.Object

org.apache.oozie.client.OozieClient

org.apache.oozie.LocalOozieClientCoord

public class LocalOozieClientCoord
extends OozieClient

Client API to submit and manage Oozie coordinator 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 coordinator application name from the coordinator 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.SORT_BY, 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_SORT_BY, 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
LocalOozieClientCoord(CoordinatorEngine coordEngine) Create a coordinator 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'.
CoordinatorAction	getCoordActionInfo(String actionId) Get the info of a coordinator action.
CoordinatorJob	getCoordJobInfo(String jobId) Get the info of a coordinator job.
CoordinatorJob	getCoordJobInfo(String jobId, String filter, int start, int len) Get the info of a coordinator job.
List<CoordinatorJob>	getCoordJobsInfo(String filter, int start, int len) Return the info of the coordinator jobs that match the filter.
String	getHeader(String name) Get the value of a set HTTP header from the coordinator instance.
Iterator<String>	getHeaderNames() Return an iterator with all the header names set in the coordinator instance.
WorkflowJob	getJobInfo(String jobId) Deprecated.
List<WorkflowJob>	getJobsInfo(String filter) Deprecated.
List<WorkflowJob>	getJobsInfo(String filter, int start, int len) Deprecated.
String	getOozieUrl() Return the Oozie URL of the coordinator client instance.
String	getProtocolUrl() Return the Oozie URL used by the client and server for WS communications.
void	kill(String jobId) Kill a coordinator job.
void	removeHeader(String name) Remove a HTTP header from the coordinator client instance.
void	reRun(String jobId, Properties conf) Deprecated.
List<CoordinatorAction>	reRunCoord(String jobId, String rerunType, String scope, boolean refresh, boolean noCleanup) Rerun coordinator actions.
List<CoordinatorAction>	reRunCoord(String jobId, String rerunType, String scope, boolean refresh, boolean noCleanup, boolean failed, Properties conf) Rerun coordinator actions with failed option.
void	resume(String jobId) Resume a coordinator job.
String	run(Properties conf) Submit and start a coordinator job.
void	setHeader(String name, String value) Set a HTTP header to be used in the WS requests by the coordinator instance.
void	start(String jobId) Deprecated.
String	submit(Properties conf) Submit a coordinator job.
void	suspend(String jobId) Suspend a coordinator 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, getCoordJobInfo, getDebugMode, getHeaders, getInstrumentation, getJavaSystemProperties, getJMSConnectionInfo, getJMSTopicName, getJobAuditLog, getJobDefinition, getJobErrorLog, getJobId, getJobInfo, getJobLog, getJobLog, getJobLog, getMetrics, getOSEnv, getQueueDump, getRetryCount, getServerBuildVersion, getServerConfiguration, getSlaInfo, getStatus, getSystemMode, getWfsForCoordAction, getWorkflowActionInfo, ignore, kill, killJobs, listShareLib, notEmpty, notNull, pollJob, reRunBundle, resumeJobs, setDebugMode, setRetryCount, setSystemMode, slaChange, slaChange, slaChange, slaDisableAlert, slaDisableAlert, slaEnableAlert, slaEnableAlert, suspendJobs, updateCoord, updateCoord, updateShareLib, validateXML, writeToXml

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalOozieClientCoord

public LocalOozieClientCoord(CoordinatorEngine coordEngine)

Create a coordinator client for Oozie local use.

Parameters:

coordEngine - the engine instance to use.

Method Detail

getOozieUrl

public String getOozieUrl()

Return the Oozie URL of the coordinator 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 coordinator 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 coordinator 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 coordinator 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 coordinator 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 coordinator instance.

Overrides:

getHeaderNames in class OozieClient

Returns:

header names.

submit

public String submit(Properties conf)
              throws OozieClientException

Submit a coordinator 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

@Deprecated
public void start(String jobId)
           throws OozieClientException

Deprecated.

Start a coordinator 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 coordinator 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

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

Deprecated.

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.

reRunCoord

public List<CoordinatorAction> reRunCoord(String jobId,
                                 String rerunType,
                                 String scope,
                                 boolean refresh,
                                 boolean noCleanup)
                                   throws OozieClientException

Rerun coordinator actions.

Overrides:

reRunCoord in class OozieClient

Parameters:

jobId - coordinator jobId

rerunType - rerun type 'date' if -date is used, 'action-id' if -action is used

scope - rerun scope for date or actionIds

refresh - true if -refresh is given in command option

noCleanup - true if -nocleanup is given in command option

Throws:

OozieClientException

reRunCoord

public List<CoordinatorAction> reRunCoord(String jobId,
                                 String rerunType,
                                 String scope,
                                 boolean refresh,
                                 boolean noCleanup,
                                 boolean failed,
                                 Properties conf)
                                   throws OozieClientException

Rerun coordinator actions with failed option.

Overrides:

reRunCoord in class OozieClient

Parameters:

jobId - coordinator jobId

rerunType - rerun type 'date' if -date is used, 'action-id' if -action is used

scope - rerun scope for date or actionIds

refresh - true if -refresh is given in command option

noCleanup - true if -nocleanup is given in command option

failed - true if -failed is given in command option

conf - configuration information for the rerun

Throws:

OozieClientException

suspend

public void suspend(String jobId)
             throws OozieClientException

Suspend a coordinator 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 coordinator 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 coordinator job.

Overrides:

kill in class OozieClient

Parameters:

jobId - job Id.

Throws:

OozieClientException - thrown if the job could not be killed.

getJobInfo

@Deprecated
public WorkflowJob getJobInfo(String jobId)
                       throws OozieClientException

Deprecated.

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.

getCoordJobInfo

public CoordinatorJob getCoordJobInfo(String jobId)
                               throws OozieClientException

Get the info of a coordinator job.

Overrides:

getCoordJobInfo in class OozieClient

Parameters:

jobId - job Id.

Returns:

the job info.

Throws:

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

getCoordJobInfo

public CoordinatorJob getCoordJobInfo(String jobId,
                             String filter,
                             int start,
                             int len)
                               throws OozieClientException

Get the info of a coordinator job.

Overrides:

getCoordJobInfo in class OozieClient

Parameters:

jobId - job Id.

filter - filter the status filter

start - starting index in the list of actions belonging to the job

len - number of actions to be returned

Returns:

the job info.

Throws:

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

getCoordActionInfo

public CoordinatorAction getCoordActionInfo(String actionId)
                                     throws OozieClientException

Get the info of a coordinator action.

Overrides:

getCoordActionInfo in class OozieClient

Parameters:

actionId - Id.

Returns:

the coordinator action info.

Throws:

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

getJobsInfo

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

Deprecated.

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

Overrides:

getJobsInfo in class OozieClient

Parameters:

filter - job filter. Refer to the OozieClient 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.

getCoordJobsInfo

public List<CoordinatorJob> getCoordJobsInfo(String filter,
                                    int start,
                                    int len)
                                      throws OozieClientException

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

Overrides:

getCoordJobsInfo in class OozieClient

Parameters:

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

start - jobs offset, base 1.

len - number of jobs to return.

Returns:

a list with the coordinator jobs info

Throws:

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

getJobsInfo

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

Deprecated.

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.