drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jacq...@apache.org
Subject [11/12] drill git commit: DRILL-4241: Timestamps should divide by 1000 in reader
Date Mon, 11 Jan 2016 07:53:59 GMT
DRILL-4241: Timestamps should divide by 1000 in reader


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

Branch: refs/heads/master
Commit: 3694909662d62772ea146c073bdb2d6f10e4150e
Parents: 54cf727
Author: Todd Lipcon <todd@cloudera.com>
Authored: Thu Nov 19 16:19:45 2015 -0800
Committer: Jacques Nadeau <jacques@apache.org>
Committed: Sun Jan 10 22:54:21 2016 -0800

----------------------------------------------------------------------
 .../java/org/apache/drill/exec/store/kudu/KuduRecordReader.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/36949096/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java
----------------------------------------------------------------------
diff --git a/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java
b/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java
index 7f7fc35..a97df77 100644
--- a/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java
+++ b/contrib/storage-kudu/src/main/java/org/apache/drill/exec/store/kudu/KuduRecordReader.java
@@ -315,10 +315,10 @@ public class KuduRecordReader extends AbstractRecordReader {
       case TIMESTAMP:
         if (pci.kuduColumn.isNullable()) {
           ((NullableTimeStampVector.Mutator)pci.vv.getMutator())
-            .setSafe(rowIndex, result.getLong(pci.index));
+            .setSafe(rowIndex, result.getLong(pci.index) / 1000);
         } else {
           ((TimeStampVector.Mutator)pci.vv.getMutator())
-            .setSafe(rowIndex, result.getLong(pci.index));
+            .setSafe(rowIndex, result.getLong(pci.index) / 1000);
         }
         break;
       default:


Mime
View raw message