org.finra.herd.dao.impl

Class OozieDaoImpl

java.lang.Object

org.finra.herd.dao.impl.OozieDaoImpl

All Implemented Interfaces:

OozieDao

@Repository
public class OozieDaoImpl
extends Object
implements OozieDao

The Oozie DAO implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTION_NAME_CLIENT_WORKFLOW
static String	HERD_OOZIE_WRAPPER_WORKFLOW_NAME
static String	OOZIE_ERROR_CODE_JOB_DOES_NOT_EXIST
static String	OOZIE_WORKFLOW_JOB_STATUS_DM_FAILED
static String	OOZIE_WORKFLOW_JOB_STATUS_DM_PREP

Constructor Summary

Constructors

Constructor and Description
OozieDaoImpl()

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)

Methods inherited from class java.lang.Object

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

Field Detail

OOZIE_WORKFLOW_JOB_STATUS_DM_PREP

public static final String OOZIE_WORKFLOW_JOB_STATUS_DM_PREP

See Also:

Constant Field Values

OOZIE_WORKFLOW_JOB_STATUS_DM_FAILED

public static final String OOZIE_WORKFLOW_JOB_STATUS_DM_FAILED

See Also:

Constant Field Values

OOZIE_ERROR_CODE_JOB_DOES_NOT_EXIST

public static final String OOZIE_ERROR_CODE_JOB_DOES_NOT_EXIST

See Also:

Constant Field Values

HERD_OOZIE_WRAPPER_WORKFLOW_NAME

public static final String HERD_OOZIE_WRAPPER_WORKFLOW_NAME

See Also:

Constant Field Values

ACTION_NAME_CLIENT_WORKFLOW

public static final String ACTION_NAME_CLIENT_WORKFLOW

See Also:

Constant Field Values

Constructor Detail

OozieDaoImpl

public OozieDaoImpl()

Method Detail

runOozieWorkflow

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

Specified by:

runOozieWorkflow in interface OozieDao

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

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

Description copied from interface: OozieDao

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

Specified by:

getEmrOozieWorkflow in interface OozieDao

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

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

Description copied from interface: OozieDao

Gets the oozie jobs in RUNNING status.

Specified by:

getRunningEmrOozieJobsByName in interface OozieDao

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