You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2018/08/08 20:31:25 UTC

hive git commit: HIVE-20279 : HiveContextAwareRecordReader slows down Druid Scan queries. (Nishant Bangarwa via Ashutosh Chauhan)

Repository: hive
Updated Branches:
  refs/heads/master 7dce7b79b -> 3f3d9189f


HIVE-20279 : HiveContextAwareRecordReader slows down Druid Scan queries. (Nishant Bangarwa via Ashutosh Chauhan)

Signed-off-by: Ashutosh Chauhan <ha...@apache.org>


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

Branch: refs/heads/master
Commit: 3f3d9189fe6bac9382eb1e6a5f9547c1b969a14a
Parents: 7dce7b7
Author: Nishant Bangarwa <ni...@gmail.com>
Authored: Wed Aug 8 13:30:21 2018 -0700
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Wed Aug 8 13:31:10 2018 -0700

----------------------------------------------------------------------
 .../apache/hadoop/hive/druid/serde/DruidQueryRecordReader.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/3f3d9189/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidQueryRecordReader.java
----------------------------------------------------------------------
diff --git a/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidQueryRecordReader.java b/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidQueryRecordReader.java
index 215f4a2..78406bd 100644
--- a/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidQueryRecordReader.java
+++ b/druid-handler/src/java/org/apache/hadoop/hive/druid/serde/DruidQueryRecordReader.java
@@ -142,7 +142,10 @@ public abstract class DruidQueryRecordReader<T extends BaseQuery<R>, R extends C
 
   @Override
   public long getPos() {
-    return 0;
+    // HiveContextAwareRecordReader uses this position to track the block position and check
+    // whether to skip header and footer. return -1 to since we need not skip any header and
+    // footer rows for druid.
+    return -1;
   }
 
   @Override