public class TezCompiler extends TaskCompiler
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
LOG |
conf, console, db, queryState
Constructor and Description |
---|
TezCompiler() |
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) |
void |
init(QueryState queryState,
SessionState.LogHelper console,
Hive db) |
protected void |
optimizeOperatorPlan(ParseContext pCtx,
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) |
compile, genColumnStatsTask, getLeafTasks, getParseContext
public void init(QueryState queryState, SessionState.LogHelper console, Hive db)
init
in class TaskCompiler
protected void optimizeOperatorPlan(ParseContext pCtx, Set<ReadEntity> inputs, Set<WriteEntity> outputs) throws SemanticException
optimizeOperatorPlan
in class TaskCompiler
SemanticException
protected void generateTaskTree(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, List<Task<MoveWork>> mvTask, Set<ReadEntity> inputs, Set<WriteEntity> outputs) throws SemanticException
generateTaskTree
in class TaskCompiler
SemanticException
protected void setInputFormat(Task<? extends Serializable> task)
setInputFormat
in class TaskCompiler
protected void decideExecMode(List<Task<? extends Serializable>> rootTasks, Context ctx, GlobalLimitCtx globalLimitCtx) throws SemanticException
decideExecMode
in class TaskCompiler
SemanticException
protected void optimizeTaskPlan(List<Task<? extends Serializable>> rootTasks, ParseContext pCtx, Context ctx) throws SemanticException
optimizeTaskPlan
in class TaskCompiler
SemanticException
Copyright © 2016 The Apache Software Foundation. All rights reserved.