org.apache.oozie.coord.input.logic

Class CoordInputLogicEvaluatorPhaseTwo

java.lang.Object

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

org.apache.oozie.coord.input.logic.CoordInputLogicEvaluatorPhaseTwo

All Implemented Interfaces:

CoordInputLogicEvaluator

public class CoordInputLogicEvaluatorPhaseTwo
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
CoordInputLogicEvaluatorPhaseTwo(CoordinatorActionBean coordAction, AbstractCoordInputDependency coordInputDependency)
CoordInputLogicEvaluatorPhaseTwo(CoordinatorActionBean coordAction, Date actualTime)

Method Summary

Methods

Modifier and Type	Method and Description
CoordInputLogicEvaluatorResult	evalCombineInput(String[] inputSets, int min, int wait) Eval combine input.
CoordInputLogicEvaluatorResult	evalInput(String dataSet, int min, int wait) Eval input.

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

combine, getConf, getEvalResult, getEvalResult, getListAsString, getResultFromPullPush, input, isInputWaitElapsed, pathExists

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordInputLogicEvaluatorPhaseTwo

public CoordInputLogicEvaluatorPhaseTwo(CoordinatorActionBean coordAction,
                                Date actualTime)

CoordInputLogicEvaluatorPhaseTwo

public CoordInputLogicEvaluatorPhaseTwo(CoordinatorActionBean coordAction,
                                AbstractCoordInputDependency coordInputDependency)

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