hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jcama...@apache.org
Subject hive git commit: HIVE-16482: Druid Ser/Des need to use dimension output name (Slim Bouguerra, reviewed by Jesus Camacho Rodriguez)
Date Wed, 19 Apr 2017 23:06:34 GMT
Repository: hive
Updated Branches:
  refs/heads/master 39c7f20da -> 3a5edc97e


HIVE-16482: Druid Ser/Des need to use dimension output name (Slim Bouguerra, reviewed by Jesus
Camacho Rodriguez)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/3a5edc97
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/3a5edc97
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/3a5edc97

Branch: refs/heads/master
Commit: 3a5edc97e562661b7e54b970c2fc123a26e79708
Parents: 39c7f20
Author: Slim Bouguerra <slim.bouguerra@gmail.com>
Authored: Thu Apr 20 00:06:04 2017 +0100
Committer: Jesus Camacho Rodriguez <jcamacho@apache.org>
Committed: Thu Apr 20 00:06:04 2017 +0100

----------------------------------------------------------------------
 .../hive/druid/serde/DruidGroupByQueryRecordReader.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/3a5edc97/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidGroupByQueryRecordReader.java
----------------------------------------------------------------------
diff --git a/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidGroupByQueryRecordReader.java
b/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidGroupByQueryRecordReader.java
index 9e8b439..f0bdb9e 100644
--- a/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidGroupByQueryRecordReader.java
+++ b/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidGroupByQueryRecordReader.java
@@ -99,7 +99,7 @@ public class DruidGroupByQueryRecordReader
         indexes[i]--;
         for (int j = i + 1; j < indexes.length; j++) {
           indexes[j] = current.getDimension(
-                  query.getDimensions().get(j).getDimension()).size() - 1;
+                  query.getDimensions().get(j).getOutputName()).size() - 1;
         }
         return true;
       }
@@ -110,7 +110,7 @@ public class DruidGroupByQueryRecordReader
       indexes = new int[query.getDimensions().size()];
       for (int i = 0; i < query.getDimensions().size(); i++) {
         DimensionSpec ds = query.getDimensions().get(i);
-        indexes[i] = current.getDimension(ds.getDimension()).size() - 1;
+        indexes[i] = current.getDimension(ds.getOutputName()).size() - 1;
       }
       return true;
     }
@@ -131,7 +131,7 @@ public class DruidGroupByQueryRecordReader
     // 2) The dimension columns
     for (int i = 0; i < query.getDimensions().size(); i++) {
       DimensionSpec ds = query.getDimensions().get(i);
-      List<String> dims = current.getDimension(ds.getDimension());
+      List<String> dims = current.getDimension(ds.getOutputName());
       if (dims.size() == 0) {
         // NULL value for dimension
         value.getValue().put(ds.getOutputName(), null);
@@ -170,7 +170,7 @@ public class DruidGroupByQueryRecordReader
       // 2) The dimension columns
       for (int i = 0; i < query.getDimensions().size(); i++) {
         DimensionSpec ds = query.getDimensions().get(i);
-        List<String> dims = current.getDimension(ds.getDimension());
+        List<String> dims = current.getDimension(ds.getOutputName());
         if (dims.size() == 0) {
           // NULL value for dimension
           value.getValue().put(ds.getOutputName(), null);


Mime
View raw message