org.apache.oozie
Class DagELFunctions

java.lang.Object
  extended by org.apache.oozie.DagELFunctions

public class DagELFunctions
extends Object

DAG EL functions.


Field Summary
static String HADOOP_JOBS_PREFIX
           
 
Constructor Summary
DagELFunctions()
           
 
Method Summary
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, org.apache.oozie.client.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,
                                 org.apache.oozie.client.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)


Copyright © 2012 Apache Software Foundation. All Rights Reserved.