diff --git ql/src/java/org/apache/hadoop/hive/ql/parse/TaskCompiler.java ql/src/java/org/apache/hadoop/hive/ql/parse/TaskCompiler.java index dbcac8b..248eb03 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/TaskCompiler.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/TaskCompiler.java @@ -93,6 +93,8 @@ public void compile(final ParseContext pCtx, final List> rootTa protected abstract void generateCountersTask(Task rootTask); /* + * Called at the beginning of the compile phase to have another chance to optimize the operator plan + */ + protected void optimizeOperatorPlan(ParseContext pCtxSet, Set inputs, + Set outputs) throws SemanticException { + } + + /* * Called after the tasks have been generated to run another round of optimization */ protected abstract void optimizeTaskPlan(List> rootTasks,