org.apache.oozie.coord
Class CoordELEvaluator

java.lang.Object
  extended by org.apache.oozie.coord.CoordELEvaluator

public class CoordELEvaluator
extends Object

This class provide different evaluators required at different stages


Field Summary
static Integer HOUR
           
static Integer MINUTE
           
 
Constructor Summary
CoordELEvaluator()
           
 
Method Summary
static ELEvaluator createDataEvaluator(org.jdom.Element eJob, org.apache.hadoop.conf.Configuration conf, String actionId)
          Create an Evaluator to resolve dataIns and dataOuts of an application instance (used in stage 3)
static ELEvaluator createELEvaluatorForDataEcho(org.apache.hadoop.conf.Configuration conf, String group, HashMap<String,String> dataNameList)
           
static ELEvaluator createELEvaluatorForGroup(org.apache.hadoop.conf.Configuration conf, String group)
          Create an evaluator to be used in resolving configuration vars and frequency constant/functions (used in Stage 1)
static ELEvaluator createInstancesELEvaluator(org.jdom.Element event, SyncCoordAction appInst, org.apache.hadoop.conf.Configuration conf)
          Create a new Evaluator to resolve the EL functions and variables using action creation time (Phase 2)
static ELEvaluator createInstancesELEvaluator(String tag, org.jdom.Element event, SyncCoordAction appInst, org.apache.hadoop.conf.Configuration conf)
           
static ELEvaluator createLazyEvaluator(Date actualTime, Date nominalTime, org.jdom.Element dEvent, org.apache.hadoop.conf.Configuration conf)
          Create a new evaluator for Lazy resolve (phase 3).
static ELEvaluator createSLAEvaluator(Date nominalTime, org.apache.hadoop.conf.Configuration conf)
          Create a SLA evaluator to be used during Materialization
static ELEvaluator createURIELEvaluator(String strDate)
          Create a new Evaluator to resolve URI temple with time specific constant
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

MINUTE

public static final Integer MINUTE

HOUR

public static final Integer HOUR
Constructor Detail

CoordELEvaluator

public CoordELEvaluator()
Method Detail

createELEvaluatorForGroup

public static ELEvaluator createELEvaluatorForGroup(org.apache.hadoop.conf.Configuration conf,
                                                    String group)
Create an evaluator to be used in resolving configuration vars and frequency constant/functions (used in Stage 1)

Parameters:
conf - : Configuration containing property variables
Returns:
configured ELEvaluator

createInstancesELEvaluator

public static ELEvaluator createInstancesELEvaluator(org.jdom.Element event,
                                                     SyncCoordAction appInst,
                                                     org.apache.hadoop.conf.Configuration conf)
                                              throws Exception
Create a new Evaluator to resolve the EL functions and variables using action creation time (Phase 2)

Parameters:
event - : Xml element for data-in element usually enclosed by tag
appInst - : Application Instance related information such as Action creation Time
conf - :Configuration to substitute any variables
Returns:
configured ELEvaluator
Throws:
Exception - : If there is any date-time string in wrong format, the exception is thrown

createInstancesELEvaluator

public static ELEvaluator createInstancesELEvaluator(String tag,
                                                     org.jdom.Element event,
                                                     SyncCoordAction appInst,
                                                     org.apache.hadoop.conf.Configuration conf)
                                              throws Exception
Throws:
Exception

createELEvaluatorForDataEcho

public static ELEvaluator createELEvaluatorForDataEcho(org.apache.hadoop.conf.Configuration conf,
                                                       String group,
                                                       HashMap<String,String> dataNameList)
                                                throws Exception
Throws:
Exception

createLazyEvaluator

public static ELEvaluator createLazyEvaluator(Date actualTime,
                                              Date nominalTime,
                                              org.jdom.Element dEvent,
                                              org.apache.hadoop.conf.Configuration conf)
                                       throws Exception
Create a new evaluator for Lazy resolve (phase 3). For example, coord_latest(n) and coord_actualTime()function should be resolved when all other data dependencies are met.

Parameters:
actualTime - : Action start time
nominalTime - : Action creation time
dEvent - :XML element for data-in element usually enclosed by tag
conf - :Configuration to substitute any variables
Returns:
configured ELEvaluator
Throws:
Exception - : If there is any date-time string in wrong format, the exception is thrown

createSLAEvaluator

public static ELEvaluator createSLAEvaluator(Date nominalTime,
                                             org.apache.hadoop.conf.Configuration conf)
                                      throws Exception
Create a SLA evaluator to be used during Materialization

Parameters:
nominalTime -
conf -
Returns:
Throws:
Exception

createDataEvaluator

public static ELEvaluator createDataEvaluator(org.jdom.Element eJob,
                                              org.apache.hadoop.conf.Configuration conf,
                                              String actionId)
                                       throws Exception
Create an Evaluator to resolve dataIns and dataOuts of an application instance (used in stage 3)

Parameters:
eJob - : XML element for the application instance
conf - :Configuration to substitute any variables
Returns:
configured ELEvaluator
Throws:
Exception - : If there is any date-time string in wrong format, the exception is thrown

createURIELEvaluator

public static ELEvaluator createURIELEvaluator(String strDate)
                                        throws Exception
Create a new Evaluator to resolve URI temple with time specific constant

Parameters:
strDate - : Date-time
Returns:
configured ELEvaluator
Throws:
Exception - If there is any date-time string in wrong format, the exception is thrown


Copyright © 2013 Apache Software Foundation. All Rights Reserved.