Uses of Class
org.apache.hadoop.hive.ql.exec.ConditionalTask

Packages that use ConditionalTask

Package	Description
org.apache.hadoop.hive.ql.optimizer
org.apache.hadoop.hive.ql.optimizer.physical

Uses of ConditionalTask in org.apache.hadoop.hive.ql.optimizer

Methods in org.apache.hadoop.hive.ql.optimizer that return ConditionalTask

Modifier and Type	Method and Description
static ConditionalTask	GenMapRedUtils.createCondTask(HiveConf conf, Task<? extends Serializable> currTask, MoveWork mvWork, Serializable mergeWork, String inputPath) Construct a conditional task given the current leaf task, the MoveWork and the MapredWork.

Methods in org.apache.hadoop.hive.ql.optimizer with parameters of type ConditionalTask

Modifier and Type	Method and Description
static void	GenMapRedUtils.linkMoveTask(FileSinkOperator newOutput, ConditionalTask cndTsk, List<Task<MoveWork>> mvTasks, HiveConf hconf, DependencyCollectionTask dependencyTask) Make the move task in the GenMRProcContext following the FileSinkOperator a dependent of all possible subtrees branching from the ConditionalTask.

Uses of ConditionalTask in org.apache.hadoop.hive.ql.optimizer.physical

Methods in org.apache.hadoop.hive.ql.optimizer.physical with parameters of type ConditionalTask

Modifier and Type	Method and Description
Task<? extends Serializable>	SortMergeJoinTaskDispatcher.processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context)
Task<? extends Serializable>	CommonJoinTaskDispatcher.processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context)
abstract Task<? extends Serializable>	AbstractJoinTaskDispatcher.processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context)
protected void	AbstractJoinTaskDispatcher.replaceTaskWithConditionalTask(Task<? extends Serializable> currTask, ConditionalTask cndTsk)