org.apache.oozie.coord.input.logic

Class CoordInputLogicEvaluatorPhaseThree

java.lang.Object

org.apache.oozie.coord.input.logic.CoordInputLogicEvaluatorPhaseOne

org.apache.oozie.coord.input.logic.CoordInputLogicEvaluatorPhaseThree

All Implemented Interfaces:

CoordInputLogicEvaluator

public class CoordInputLogicEvaluatorPhaseThree
extends CoordInputLogicEvaluatorPhaseOne

Field Summary

Fields inherited from class org.apache.oozie.coord.input.logic.CoordInputLogicEvaluatorPhaseOne

coordAction, coordInputDependency, dependencyMap, log

Fields inherited from interface org.apache.oozie.coord.input.logic.CoordInputLogicEvaluator

INPUT_LOGIC

Constructor Summary

Constructors

Constructor and Description
CoordInputLogicEvaluatorPhaseThree(CoordinatorActionBean coordAction, ELEvaluator eval)

Method Summary

Methods

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)

Methods inherited from class org.apache.oozie.coord.input.logic.CoordInputLogicEvaluatorPhaseOne

getConf, getEvalResult, getEvalResult, getResultFromPullPush, input

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CoordInputLogicEvaluatorPhaseThree

public CoordInputLogicEvaluatorPhaseThree(CoordinatorActionBean coordAction,
                                  ELEvaluator eval)

Method Detail

evalInput

public CoordInputLogicEvaluatorResult evalInput(String dataSet,
                                       int min,
                                       int wait)

Description copied from interface: CoordInputLogicEvaluator

Eval input.

Specified by:

evalInput in interface CoordInputLogicEvaluator

Overrides:

evalInput in class CoordInputLogicEvaluatorPhaseOne

Parameters:

dataSet - the input data set

min - the min

wait - the wait

Returns:

the coord input logic evaluator result

evalCombineInput

public CoordInputLogicEvaluatorResult evalCombineInput(String[] inputSets,
                                              int min,
                                              int wait)

Description copied from interface: CoordInputLogicEvaluator

Eval combine input.

Specified by:

evalCombineInput in interface CoordInputLogicEvaluator

Overrides:

evalCombineInput in class CoordInputLogicEvaluatorPhaseOne

Parameters:

inputSets - the combine datasets

min - the min

wait - the wait

Returns:

the coord input logic evaluator result

combine

public CoordInputLogicEvaluatorResult combine(AbstractCoordInputDependency coordInputDependency,
                                     String[] inputSets,
                                     int min,
                                     int wait)

Overrides:

combine in class CoordInputLogicEvaluatorPhaseOne

pathExists

protected boolean pathExists(String sPath,
                 org.apache.hadoop.conf.Configuration actionConf)
                      throws IOException,
                             URISyntaxException,
                             URIHandlerException

Overrides:

pathExists in class CoordInputLogicEvaluatorPhaseOne

Throws:

IOException

URISyntaxException

URIHandlerException

isInputWaitElapsed

public boolean isInputWaitElapsed(int timeInMin)

Overrides:

isInputWaitElapsed in class CoordInputLogicEvaluatorPhaseOne

getListAsString

public String getListAsString(List<String> input,
                     String dataSet)

Overrides:

getListAsString in class CoordInputLogicEvaluatorPhaseOne