org.apache.oozie

Class DagELFunctions

java.lang.Object

org.apache.oozie.DagELFunctions

public class DagELFunctions
extends Object

DAG EL functions.

Field Summary

Fields

Modifier and Type	Field and Description
static String	HADOOP_JOBS_PREFIX

Constructor Summary

Constructors

Constructor and Description
DagELFunctions()

Method Summary

Modifier and Type	Method and Description
static void	configureEvaluator(ELEvaluator evaluator, WorkflowJobBean workflow, WorkflowActionBean action)
static WorkflowActionBean	getAction()
static String	getActionVar(String actionName, String varName)
static org.apache.hadoop.conf.Configuration	getProtoActionConf()
static WorkflowJobBean	getWorkflow()
static void	setActionInfo(WorkflowInstance workflowInstance, WorkflowAction action)
static Map<String,String>	wf_actionData(String actionName) Return the action data for an action.
static String	wf_actionExternalId(String actionName) Return the external ID of an action.
static String	wf_actionExternalStatus(String actionName) Return the action external status.
static String	wf_actionTrackerUri(String actionName) Return the tracker URI of an action.
static String	wf_appPath() Return the application path.
static String	wf_callback(String externalStatusVar) Create a callback URL for the current action.
static String	wf_conf(String property) Return a job configuration property.
static String	wf_errorCode(String actionName) Return the error code for an action.
static String	wf_errorMessage(String actionName) Return the error message for an action.
static String	wf_group() Return the job owner group name.
static String	wf_id() Return the job Id.
static String	wf_lastErrorNode() Return the name of the last action that ended in error.
static String	wf_name() Return the application name.
static int	wf_run() Return the workflow run number, unless a rerun it is always 1.
static String	wf_transition(String actionName) Return the transition taken by a workflow job action/decision action.
static String	wf_user() Return the job owner user name.

Methods inherited from class java.lang.Object

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

Field Detail

HADOOP_JOBS_PREFIX

public static final String HADOOP_JOBS_PREFIX

See Also:

Constant Field Values

Constructor Detail

DagELFunctions

public DagELFunctions()

Method Detail

configureEvaluator

public static void configureEvaluator(ELEvaluator evaluator,
                                      WorkflowJobBean workflow,
                                      WorkflowActionBean action)

getAction

public static WorkflowActionBean getAction()

getWorkflow

public static WorkflowJobBean getWorkflow()

getProtoActionConf

public static org.apache.hadoop.conf.Configuration getProtoActionConf()

setActionInfo

public static void setActionInfo(WorkflowInstance workflowInstance,
                                 WorkflowAction action)

wf_id

public static String wf_id()

Return the job Id.

Returns:

the job Id.

wf_name

public static String wf_name()

Return the application name.

Returns:

the application name.

wf_appPath

public static String wf_appPath()

Return the application path.

Returns:

the application path.

wf_conf

public static String wf_conf(String property)

Return a job configuration property.

Parameters:

property - property name.

Returns:

the value of the property, null if the property is undefined.

wf_user

public static String wf_user()

Return the job owner user name.

Returns:

the job owner user name.

wf_group

public static String wf_group()

Return the job owner group name.

Returns:

the job owner group name.

wf_callback

public static String wf_callback(String externalStatusVar)

Create a callback URL for the current action.

Parameters:

externalStatusVar - variable for the caller to inject the external status.

Returns:

the callback URL for the current action.

wf_transition

public static String wf_transition(String actionName)

Return the transition taken by a workflow job action/decision action.

Parameters:

actionName - action/decision action name.

Returns:

the transition taken, null if the action has not completed yet.

wf_lastErrorNode

public static String wf_lastErrorNode()

Return the name of the last action that ended in error.

Returns:

the name of the last action that ended in error, null if no action in the workflow job has ended in error.

wf_errorCode

public static String wf_errorCode(String actionName)

Return the error code for an action.

Parameters:

actionName - action name.

Returns:

the error code for the action, null if the action has not ended in error.

wf_errorMessage

public static String wf_errorMessage(String actionName)

Return the error message for an action.

Parameters:

actionName - action name.

Returns:

the error message for the action, null if the action has not ended in error.

wf_run

public static int wf_run()

Return the workflow run number, unless a rerun it is always 1.

Returns:

the workflow run number, unless a rerun it is always 1.

wf_actionData

public static Map<String,String> wf_actionData(String actionName)

Return the action data for an action.

Parameters:

actionName - action name.

Returns:

value of the property.

wf_actionExternalId

public static String wf_actionExternalId(String actionName)

Return the external ID of an action.

Parameters:

actionName - action name.

Returns:

the external ID of an action.

wf_actionTrackerUri

public static String wf_actionTrackerUri(String actionName)

Return the tracker URI of an action.

Parameters:

actionName - action name.

Returns:

the tracker URI of an action.

wf_actionExternalStatus

public static String wf_actionExternalStatus(String actionName)

Return the action external status.

Parameters:

actionName - action/decision action name.

Returns:

the action external status.

getActionVar

public static String getActionVar(String actionName,
                                  String varName)