org.finra.herd.dao.impl

Class OozieOperationsImpl

java.lang.Object

org.finra.herd.dao.impl.OozieOperationsImpl

All Implemented Interfaces:

OozieOperations

public class OozieOperationsImpl
extends Object
implements OozieOperations

Implementation of the Oozie operations.

Constructor Summary

Constructors

Constructor and Description
OozieOperationsImpl()

Method Summary

Modifier and Type	Method and Description
org.apache.oozie.client.WorkflowJob	getJobInfo(org.apache.oozie.client.OozieClient oozieClient, String jobId) Gets the ozie workflow job info.
List<org.apache.oozie.client.WorkflowJob>	getJobsInfo(org.apache.oozie.client.OozieClient oozieClient, String filter, int start, int len) Gets the oozie jobs.
String	runOozieWorkflow(org.apache.oozie.client.OozieClient oozieClient, Properties conf) Runs the ozie workflow.

Methods inherited from class java.lang.Object

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

Constructor Detail

OozieOperationsImpl

public OozieOperationsImpl()

Method Detail

runOozieWorkflow

public String runOozieWorkflow(org.apache.oozie.client.OozieClient oozieClient,
                               Properties conf)
                        throws org.apache.oozie.client.OozieClientException

Description copied from interface: OozieOperations

Runs the ozie workflow.

Specified by:

runOozieWorkflow in interface OozieOperations

Parameters:

oozieClient - the oozie client

conf - the configuraton properties.

Returns:

the oozie workflow job id.

Throws:

org.apache.oozie.client.OozieClientException

getJobInfo

public org.apache.oozie.client.WorkflowJob getJobInfo(org.apache.oozie.client.OozieClient oozieClient,
                                                      String jobId)
                                               throws org.apache.oozie.client.OozieClientException

Description copied from interface: OozieOperations

Gets the ozie workflow job info.

Specified by:

getJobInfo in interface OozieOperations

Parameters:

oozieClient - the oozie client

jobId - the oozie workflow job id.

Returns:

the workflow job

Throws:

org.apache.oozie.client.OozieClientException

getJobsInfo

public List<org.apache.oozie.client.WorkflowJob> getJobsInfo(org.apache.oozie.client.OozieClient oozieClient,
                                                             String filter,
                                                             int start,
                                                             int len)
                                                      throws org.apache.oozie.client.OozieClientException

Description copied from interface: OozieOperations

Gets the oozie jobs.

Specified by:

getJobsInfo in interface OozieOperations

Parameters:

oozieClient - the oozie client

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

start - jobs offset, base 1.

len - number of jobs to return.

Returns:

the list of job information.

Throws:

org.apache.oozie.client.OozieClientException - if any problems were encountered.