public class CoordELEvaluator extends Object
Modifier and Type | Field and Description |
---|---|
static Integer |
HOUR |
static Integer |
MINUTE |
Constructor and Description |
---|
CoordELEvaluator() |
Modifier and Type | Method and Description |
---|---|
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 |
createDataEvaluator(org.jdom.Element eJob,
org.apache.hadoop.conf.Configuration conf,
String actionId,
CoordInputDependency pullDependencies,
CoordInputDependency pushDependencies) |
static ELEvaluator |
createELEvaluatorForDataAndConf(org.apache.hadoop.conf.Configuration conf,
String group,
HashMap<String,String> dataNameList)
Create an Evaluator using conf and input/output-data (used for sla)
|
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(org.jdom.Element eAction,
CoordinatorActionBean coordAction,
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
|
public CoordELEvaluator()
public static ELEvaluator createELEvaluatorForGroup(org.apache.hadoop.conf.Configuration conf, String group)
conf
- : Configuration containing property variablesgroup
- Name of the group of required EL Evaluator.public static ELEvaluator createInstancesELEvaluator(org.jdom.Element event, SyncCoordAction appInst, org.apache.hadoop.conf.Configuration conf) throws Exception
event
- : Xml element for data-in element usually enclosed by <data-in(out)> tagappInst
- : Application Instance related information such as Action creation Timeconf
- :Configuration to substitute any variablesException
- : If there is any date-time string in wrong format, the exception is thrownpublic static ELEvaluator createInstancesELEvaluator(String tag, org.jdom.Element event, SyncCoordAction appInst, org.apache.hadoop.conf.Configuration conf) throws Exception
Exception
public static ELEvaluator createELEvaluatorForDataEcho(org.apache.hadoop.conf.Configuration conf, String group, HashMap<String,String> dataNameList) throws Exception
Exception
public static ELEvaluator createLazyEvaluator(Date actualTime, Date nominalTime, org.jdom.Element dEvent, org.apache.hadoop.conf.Configuration conf) throws Exception
actualTime
- : Action start timenominalTime
- : Action creation timedEvent
- :XML element for data-in element usually enclosed by <data-in(out)> tagconf
- :Configuration to substitute any variablesException
- : If there is any date-time string in wrong format, the exception is thrownpublic static ELEvaluator createSLAEvaluator(org.jdom.Element eAction, CoordinatorActionBean coordAction, org.apache.hadoop.conf.Configuration conf) throws Exception
eAction
- the actioncoordAction
- the coordinator actionconf
- the configurationException
- in case of errorpublic static ELEvaluator createELEvaluatorForDataAndConf(org.apache.hadoop.conf.Configuration conf, String group, HashMap<String,String> dataNameList) throws Exception
conf
- the configurationgroup
- the group for the EL expressiondataNameList
- the name list for the dataException
- in case of errorpublic static ELEvaluator createDataEvaluator(org.jdom.Element eJob, org.apache.hadoop.conf.Configuration conf, String actionId) throws Exception
eJob
- : XML element for the application instanceconf
- :Configuration to substitute any variablesactionId
- the action IdException
- : If there is any date-time string in wrong format, the exception is thrownpublic static ELEvaluator createDataEvaluator(org.jdom.Element eJob, org.apache.hadoop.conf.Configuration conf, String actionId, CoordInputDependency pullDependencies, CoordInputDependency pushDependencies) throws Exception
Exception
public static ELEvaluator createURIELEvaluator(String strDate) throws Exception
strDate
- : Date-timeException
- If there is any date-time string in wrong format, the exception is thrownCopyright © 2018 Apache Software Foundation. All rights reserved.