Repository: hive Updated Branches: refs/heads/master 67b9dc50f -> 121d70f1c
HIVE-13629 : Expose Merge-File task and Column-Truncate task from DDLTask (zhihai xu, reviewed by Sergey Shelukhin) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/121d70f1 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/121d70f1 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/121d70f1 Branch: refs/heads/master Commit: 121d70f1c0a1130595337db68a0732a51d2e7c68 Parents: 67b9dc5 Author: Sergey Shelukhin <[email protected]> Authored: Mon May 2 11:55:30 2016 -0700 Committer: Sergey Shelukhin <[email protected]> Committed: Mon May 2 11:55:30 2016 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/121d70f1/ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java index cbeb361..39a1efc 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java @@ -251,6 +251,11 @@ public class DDLTask extends Task<DDLWork> implements Serializable { private MetaDataFormatter formatter; private final HiveAuthorizationTranslator defaultAuthorizationTranslator = new DefaultHiveAuthorizationTranslator(); + private Task<? extends Serializable> subtask = null; + + public Task<? extends Serializable> getSubtask() { + return subtask; + } @Override public boolean requireLock() { @@ -667,6 +672,7 @@ public class DDLTask extends Task<DDLWork> implements Serializable { // initialize the task and execute task.initialize(queryState, getQueryPlan(), driverCxt, opContext); + subtask = task; int ret = task.execute(driverCxt); return ret; } @@ -4173,6 +4179,7 @@ public class DDLTask extends Task<DDLWork> implements Serializable { taskExec.initialize(queryState, null, driverCxt, null); taskExec.setWork(truncateWork); taskExec.setQueryPlan(this.getQueryPlan()); + subtask = taskExec; return taskExec.execute(driverCxt); }
