org.apache.oozie.coord.input.logic

Class CoordInputLogicEvaluatorPhaseValidate

java.lang.Object

org.apache.oozie.coord.input.logic.CoordInputLogicEvaluatorPhaseValidate

All Implemented Interfaces:

CoordInputLogicEvaluator

public class CoordInputLogicEvaluatorPhaseValidate
extends Object
implements CoordInputLogicEvaluator

Field Summary

Fields

Modifier and Type	Field and Description
protected CoordinatorActionBean	coordAction
protected CoordinatorJob	coordJob
protected Map<String,List<CoordInputInstance>>	dependencyMap

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

INPUT_LOGIC

Constructor Summary

Constructors

Constructor and Description
CoordInputLogicEvaluatorPhaseValidate(CoordinatorActionBean coordAction)

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 java.lang.Object

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

Field Detail

dependencyMap

protected Map<String,List<CoordInputInstance>> dependencyMap

coordAction

protected CoordinatorActionBean coordAction

coordJob

protected CoordinatorJob coordJob

Constructor Detail

CoordInputLogicEvaluatorPhaseValidate

public CoordInputLogicEvaluatorPhaseValidate(CoordinatorActionBean coordAction)

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

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

Parameters:

inputSets - the combine datasets

min - the min

wait - the wait

Returns:

the coord input logic evaluator result