org.apache.hadoop.hive.ql.parse

Class MapReduceCompiler

java.lang.Object

org.apache.hadoop.hive.ql.parse.TaskCompiler

org.apache.hadoop.hive.ql.parse.MapReduceCompiler

public class MapReduceCompiler
extends TaskCompiler

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hive.ql.parse.TaskCompiler

conf, console, db, queryState

Constructor Summary

Constructors

Constructor and Description
MapReduceCompiler()

Method Summary

Modifier and Type	Method and Description
protected void	decideExecMode(List<Task<? extends Serializable>> rootTasks, Context ctx, GlobalLimitCtx globalLimitCtx)
protected void	generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs)
protected void	optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, Context ctx)
protected void	setInputFormat(Task<? extends Serializable> task)

Methods inherited from class org.apache.hadoop.hive.ql.parse.TaskCompiler

compile, genColumnStatsTask, getParseContext, init, optimizeOperatorPlan

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected final org.slf4j.Logger LOG

Constructor Detail

MapReduceCompiler

public MapReduceCompiler()

Method Detail

setInputFormat

protected void setInputFormat(Task<? extends Serializable> task)

Specified by:

setInputFormat in class TaskCompiler

decideExecMode

protected void decideExecMode(List<Task<? extends Serializable>> rootTasks,
                              Context ctx,
                              GlobalLimitCtx globalLimitCtx)
                       throws SemanticException

Specified by:

decideExecMode in class TaskCompiler

Throws:

SemanticException

optimizeTaskPlan

protected void optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks,
                                ParseContext pCtx,
                                Context ctx)
                         throws SemanticException

Specified by:

optimizeTaskPlan in class TaskCompiler

Throws:

SemanticException

generateTaskTree

protected void generateTaskTree(List<Task<? extends Serializable>> rootTasks,
                                ParseContext pCtx,
                                List<Task<MoveWork>> mvTask,
                                Set<ReadEntity> inputs,
                                Set<WriteEntity> outputs)
                         throws SemanticException

Specified by:

generateTaskTree in class TaskCompiler

Throws:

SemanticException