org.apache.oozie.coord.input.logic

Class CoordInputLogicEvaluatorPhaseOne

java.lang.Object

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

All Implemented Interfaces:

CoordInputLogicEvaluator

Direct Known Subclasses:

CoordInputLogicEvaluatorPhaseThree, CoordInputLogicEvaluatorPhaseTwo

public class CoordInputLogicEvaluatorPhaseOne
extends Object
implements CoordInputLogicEvaluator

PhaseOne is for all dependencies check, except unresolved. Unresolved will be checked as part of phaseTwo. Phasethree is only to get dependencies from dataset, no hdfs/hcat check.

Field Summary

Fields

Modifier and Type	Field and Description
protected CoordinatorActionBean	coordAction
protected AbstractCoordInputDependency	coordInputDependency
protected Map<String,List<CoordInputInstance>>	dependencyMap
protected XLog	log

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

INPUT_LOGIC

Constructor Summary

Constructors

Constructor and Description
CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction)
CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction, CoordInputDependency coordInputDependency)

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.
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)

Methods inherited from class java.lang.Object

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

Field Detail

coordInputDependency

protected AbstractCoordInputDependency coordInputDependency

dependencyMap

protected Map<String,List<CoordInputInstance>> dependencyMap

coordAction

protected CoordinatorActionBean coordAction

log

protected XLog log

Constructor Detail

CoordInputLogicEvaluatorPhaseOne

public CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction)

CoordInputLogicEvaluatorPhaseOne

public CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction,
                                CoordInputDependency 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

Parameters:

dataSet - the input data set

min - the min

wait - the wait

Returns:

the coord input logic evaluator result

input

public CoordInputLogicEvaluatorResult input(AbstractCoordInputDependency coordInputDependency,
                                   String dataSet,
                                   int min,
                                   int wait)

Evaluate input function with min and wait

Parameters:

coordInputDependency -

dataSet -

min -

wait -

Returns:

the coord input logic evaluator result

isInputWaitElapsed

public boolean isInputWaitElapsed(int timeInMin)

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

combine

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

getConf

public org.apache.hadoop.conf.Configuration getConf()
                                             throws IOException

Throws:

IOException

getListAsString

public String getListAsString(List<String> list,
                     String dataset)

getEvalResult

protected CoordInputLogicEvaluatorResult getEvalResult(boolean found,
                                           int min,
                                           int wait,
                                           List<String> availableList)

pathExists

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

Throws:

IOException

URISyntaxException

URIHandlerException

getResultFromPullPush

public CoordInputLogicEvaluatorResult getResultFromPullPush(CoordinatorActionBean coordAction,
                                                   String dataSet,
                                                   int min)

getEvalResult

public CoordInputLogicEvaluatorResult getEvalResult(AbstractCoordInputDependency coordInputDependencies,
                                           String dataSet,
                                           int min)

Gets evaluator Result

Parameters:

coordInputDependencies - the coord dependencies

dataSet - the data set

min - the min

Returns:

the coord input logic evaluator result