public class CoordInputLogicEvaluatorPhaseThree extends CoordInputLogicEvaluatorPhaseOne
coordAction, coordInputDependency, dependencyMap, log
INPUT_LOGIC
Constructor and Description |
---|
CoordInputLogicEvaluatorPhaseThree(CoordinatorActionBean coordAction,
ELEvaluator eval) |
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.
|
String |
getListAsString(List<String> input,
String dataSet) |
boolean |
isInputWaitElapsed(int timeInMin) |
protected boolean |
pathExists(String sPath,
org.apache.hadoop.conf.Configuration actionConf) |
getConf, getEvalResult, getEvalResult, getResultFromPullPush, input
public CoordInputLogicEvaluatorPhaseThree(CoordinatorActionBean coordAction, ELEvaluator eval)
public CoordInputLogicEvaluatorResult evalInput(String dataSet, int min, int wait)
CoordInputLogicEvaluator
evalInput
in interface CoordInputLogicEvaluator
evalInput
in class CoordInputLogicEvaluatorPhaseOne
dataSet
- the input data setmin
- the minwait
- the waitpublic CoordInputLogicEvaluatorResult evalCombineInput(String[] inputSets, int min, int wait)
CoordInputLogicEvaluator
evalCombineInput
in interface CoordInputLogicEvaluator
evalCombineInput
in class CoordInputLogicEvaluatorPhaseOne
inputSets
- the combine datasetsmin
- the minwait
- the waitpublic CoordInputLogicEvaluatorResult combine(AbstractCoordInputDependency coordInputDependency, String[] inputSets, int min, int wait)
combine
in class CoordInputLogicEvaluatorPhaseOne
protected boolean pathExists(String sPath, org.apache.hadoop.conf.Configuration actionConf) throws IOException, URISyntaxException, URIHandlerException
pathExists
in class CoordInputLogicEvaluatorPhaseOne
IOException
URISyntaxException
URIHandlerException
public boolean isInputWaitElapsed(int timeInMin)
isInputWaitElapsed
in class CoordInputLogicEvaluatorPhaseOne
public String getListAsString(List<String> input, String dataSet)
getListAsString
in class CoordInputLogicEvaluatorPhaseOne
Copyright © 2018 Apache Software Foundation. All rights reserved.