public class CoordInputLogicEvaluatorPhaseOne extends Object implements CoordInputLogicEvaluator
Modifier and Type | Field and Description |
---|---|
protected CoordinatorActionBean |
coordAction |
protected AbstractCoordInputDependency |
coordInputDependency |
protected Map<String,List<CoordInputInstance>> |
dependencyMap |
protected XLog |
log |
INPUT_LOGIC
Constructor and Description |
---|
CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction) |
CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction,
CoordInputDependency coordInputDependency) |
Modifier and Type | Method and Description |
---|---|
CoordInputLogicEvaluatorResult |
combine(AbstractCoordInputDependency coordInputDependency,
String[] inputSets,
int min,
int wait) |
CoordInputLogicEvaluatorResult |
evalCombineInput(String[] inputSets,
int min,
int wait)
Eval combine input.
|
CoordInputLogicEvaluatorResult |
evalInput(String dataSet,
int min,
int wait)
Eval input.
|
org.apache.hadoop.conf.Configuration |
getConf() |
CoordInputLogicEvaluatorResult |
getEvalResult(AbstractCoordInputDependency coordInputDependencies,
String dataSet,
int min)
Gets evaluator Result
|
protected CoordInputLogicEvaluatorResult |
getEvalResult(boolean found,
int min,
int wait,
List<String> availableList) |
String |
getListAsString(List<String> list,
String dataset) |
CoordInputLogicEvaluatorResult |
getResultFromPullPush(CoordinatorActionBean coordAction,
String dataSet,
int min) |
CoordInputLogicEvaluatorResult |
input(AbstractCoordInputDependency coordInputDependency,
String dataSet,
int min,
int wait)
Evaluate input function with min and wait
|
boolean |
isInputWaitElapsed(int timeInMin) |
protected boolean |
pathExists(String sPath,
org.apache.hadoop.conf.Configuration jobConf) |
protected AbstractCoordInputDependency coordInputDependency
protected Map<String,List<CoordInputInstance>> dependencyMap
protected CoordinatorActionBean coordAction
public CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction)
public CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction, CoordInputDependency coordInputDependency)
public CoordInputLogicEvaluatorResult evalInput(String dataSet, int min, int wait)
CoordInputLogicEvaluator
evalInput
in interface CoordInputLogicEvaluator
dataSet
- the input data setmin
- the minwait
- the waitpublic CoordInputLogicEvaluatorResult input(AbstractCoordInputDependency coordInputDependency, String dataSet, int min, int wait)
coordInputDependency
- dataSet
- min
- wait
- public boolean isInputWaitElapsed(int timeInMin)
public CoordInputLogicEvaluatorResult evalCombineInput(String[] inputSets, int min, int wait)
CoordInputLogicEvaluator
evalCombineInput
in interface CoordInputLogicEvaluator
inputSets
- the combine datasetsmin
- the minwait
- the waitpublic CoordInputLogicEvaluatorResult combine(AbstractCoordInputDependency coordInputDependency, String[] inputSets, int min, int wait)
public org.apache.hadoop.conf.Configuration getConf() throws IOException
IOException
public String getListAsString(List<String> list, String dataset)
protected CoordInputLogicEvaluatorResult getEvalResult(boolean found, int min, int wait, List<String> availableList)
protected boolean pathExists(String sPath, org.apache.hadoop.conf.Configuration jobConf) throws IOException, URISyntaxException, URIHandlerException
public CoordInputLogicEvaluatorResult getResultFromPullPush(CoordinatorActionBean coordAction, String dataSet, int min)
public CoordInputLogicEvaluatorResult getEvalResult(AbstractCoordInputDependency coordInputDependencies, String dataSet, int min)
coordInputDependencies
- the coord dependenciesdataSet
- the data setmin
- the minCopyright © 2016 Apache Software Foundation. All rights reserved.