org.finra.herd.dao

Interface OozieDao

All Known Implementing Classes:

OozieDaoImpl

public interface OozieDao

A DAO for oozie operations.

Method Summary

Modifier and Type	Method and Description
org.apache.oozie.client.WorkflowJob	getEmrOozieWorkflow(String masterIpAddress, String emrOozieWorkflowId) Gets the oozie workflow job from oozie server.
List<org.apache.oozie.client.WorkflowJob>	getRunningEmrOozieJobsByName(String masterIpAddress, String appName, int start, int len) Gets the oozie jobs in RUNNING status.
String	runOozieWorkflow(String masterIpAddress, String workflowLocation, List<Parameter> parameters)

Method Detail

runOozieWorkflow

String runOozieWorkflow(String masterIpAddress,
                        String workflowLocation,
                        List<Parameter> parameters)
                 throws Exception

Parameters:

masterIpAddress - the IP address of oozie master server.

workflowLocation - the location of workflow on S3.

parameters - the configuration properties for the workflow.

Returns:

the oozie workflow job id.

Throws:

Exception

getEmrOozieWorkflow

org.apache.oozie.client.WorkflowJob getEmrOozieWorkflow(String masterIpAddress,
                                                        String emrOozieWorkflowId)
                                                 throws org.apache.oozie.client.OozieClientException

Gets the oozie workflow job from oozie server. Returns null if client workflow has not started to run yet.

Parameters:

masterIpAddress - the IP address of oozie master server.

emrOozieWorkflowId - the oozie workflow job id.

Returns:

the WorkflowJob object.

Throws:

org.apache.oozie.client.OozieClientException

getRunningEmrOozieJobsByName

List<org.apache.oozie.client.WorkflowJob> getRunningEmrOozieJobsByName(String masterIpAddress,
                                                                       String appName,
                                                                       int start,
                                                                       int len)
                                                                throws org.apache.oozie.client.OozieClientException

Gets the oozie jobs in RUNNING status.

Parameters:

masterIpAddress - the IP address of oozie master server.

appName - the workflow job application name, if no application name is provided returns all workflows.

start - jobs offset, base 1.

len - number of jobs to return.

Returns:

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

Throws:

org.apache.oozie.client.OozieClientException