Uses of Class
org.apache.hadoop.hive.ql.plan.MoveWork

Packages that use MoveWork

org.apache.hadoop.hive.ql.optimizer
org.apache.hadoop.hive.ql.parse

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

Methods in org.apache.hadoop.hive.ql.optimizer that return types with arguments of type MoveWork

static Task<MoveWork>	GenMapRedUtils.findMoveTask(List<Task<MoveWork>> mvTasks, FileSinkOperator fsOp)
List<Task<MoveWork>>	GenMRProcContext.getMvTask()

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

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.

Method parameters in org.apache.hadoop.hive.ql.optimizer with type arguments of type MoveWork

static void	GenMapRedUtils.addDependentMoveTasks(Task<MoveWork> mvTask, HiveConf hconf, Task<? extends Serializable> parentTask, DependencyCollectionTask dependencyTask) Adds the dependencyTaskForMultiInsert in ctx as a dependent of parentTask.
static org.apache.hadoop.fs.Path	GenMapRedUtils.createMoveTask(Task<? extends Serializable> currTask, boolean chDir, FileSinkOperator fsOp, ParseContext parseCtx, List<Task<MoveWork>> mvTasks, HiveConf hconf, DependencyCollectionTask dependencyTask) Create and add any dependent move tasks
static void	GenMapRedUtils.createMRWorkForMergingFiles(FileSinkOperator fsInput, org.apache.hadoop.fs.Path finalName, DependencyCollectionTask dependencyTask, List<Task<MoveWork>> mvTasks, HiveConf conf, Task<? extends Serializable> currTask)
static Task<MoveWork>	GenMapRedUtils.findMoveTask(List<Task<MoveWork>> mvTasks, FileSinkOperator fsOp)
static boolean	GenMapRedUtils.isMergeRequired(List<Task<MoveWork>> mvTasks, HiveConf hconf, FileSinkOperator fsOp, Task<? extends Serializable> currTask, boolean isInsertTable) Returns true iff the fsOp requires a merge
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.
static void	GenMapRedUtils.linkMoveTask(Task<MoveWork> mvTask, Task<? extends Serializable> task, HiveConf hconf, DependencyCollectionTask dependencyTask) Follows the task tree down from task and makes all leaves parents of mvTask
void	GenMRProcContext.setMvTask(List<Task<MoveWork>> mvTask)

Constructor parameters in org.apache.hadoop.hive.ql.optimizer with type arguments of type MoveWork

GenMRProcContext(HiveConf conf, HashMap<Operator<? extends OperatorDesc>,Task<? extends Serializable>> opTaskMap, ParseContext parseCtx, List<Task<MoveWork>> mvTask, List<Task<? extends Serializable>> rootTasks, LinkedHashMap<Operator<? extends OperatorDesc>,GenMRProcContext.GenMapRedCtx> mapCurrCtx, Set<ReadEntity> inputs, Set<WriteEntity> outputs)

Uses of MoveWork in org.apache.hadoop.hive.ql.parse

Fields in org.apache.hadoop.hive.ql.parse with type parameters of type MoveWork

List<Task<MoveWork>>

GenTezProcContext.moveTask

Constructor parameters in org.apache.hadoop.hive.ql.parse with type arguments of type MoveWork

GenTezProcContext(HiveConf conf, ParseContext parseContext, List<Task<MoveWork>> moveTask, List<Task<? extends Serializable>> rootTasks, Set<ReadEntity> inputs, Set<WriteEntity> outputs)