You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by px...@apache.org on 2016/06/03 04:41:42 UTC
hive git commit: HIVE-13905: optimize
ColumnStatsTask::constructColumnStatsFromPackedRows to have lesser number of
getTable calls (Rajesh Balamohan, reviewed by Pengcheng Xiong)
Repository: hive
Updated Branches:
refs/heads/master 3b04ce3d1 -> 4dcf78fda
HIVE-13905: optimize ColumnStatsTask::constructColumnStatsFromPackedRows to have lesser number of getTable calls (Rajesh Balamohan, reviewed by Pengcheng Xiong)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/4dcf78fd
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/4dcf78fd
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/4dcf78fd
Branch: refs/heads/master
Commit: 4dcf78fdaa6aa08c5e5ae7b22721bfd145b5eed9
Parents: 3b04ce3
Author: Pengcheng Xiong <px...@apache.org>
Authored: Thu Jun 2 21:41:25 2016 -0700
Committer: Pengcheng Xiong <px...@apache.org>
Committed: Thu Jun 2 21:41:25 2016 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/4dcf78fd/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java
index 0f0df11..a183b9b 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/ColumnStatsTask.java
@@ -328,6 +328,7 @@ public class ColumnStatsTask extends Task<ColumnStatsWork> implements Serializab
List<ColumnStatistics> stats = new ArrayList<ColumnStatistics>();
InspectableObject packedRow;
+ Table tbl = db.getTable(currentDb, tableName);
while ((packedRow = ftOp.getNextRow()) != null) {
if (packedRow.oi.getCategory() != ObjectInspector.Category.STRUCT) {
throw new HiveException("Unexpected object type encountered while unpacking row");
@@ -338,7 +339,6 @@ public class ColumnStatsTask extends Task<ColumnStatsWork> implements Serializab
List<? extends StructField> fields = soi.getAllStructFieldRefs();
List<Object> list = soi.getStructFieldsDataAsList(packedRow.o);
- Table tbl = db.getTable(currentDb,tableName);
List<FieldSchema> partColSchema = tbl.getPartCols();
// Partition columns are appended at end, we only care about stats column
int numOfStatCols = isTblLevel ? fields.size() : fields.size() - partColSchema.size();