drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From prog...@apache.org
Subject [1/2] drill git commit: DRILL-4139: Add missing BIT support for Paruet partition pruning
Date Sat, 30 Sep 2017 23:01:40 GMT
Repository: drill
Updated Branches:
  refs/heads/master 8a8bf63f7 -> 5df49ab9c


DRILL-4139: Add missing BIT support for Paruet partition pruning


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

Branch: refs/heads/master
Commit: 1ea191fa351b29847e2358f5777982d602cf5ec3
Parents: 8a8bf63
Author: Przemyslaw Maciolek <pmm@collective-sense.com>
Authored: Tue May 31 20:46:53 2016 +0200
Committer: Paul Rogers <progers@maprtech.com>
Committed: Sat Sep 30 16:01:13 2017 -0700

----------------------------------------------------------------------
 .../org/apache/drill/exec/store/parquet/ParquetGroupScan.java | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/1ea191fa/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java
b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java
index 2989819..fd38127 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java
@@ -76,6 +76,7 @@ import org.apache.drill.exec.store.schedule.CompleteWork;
 import org.apache.drill.exec.store.schedule.EndpointByteMap;
 import org.apache.drill.exec.store.schedule.EndpointByteMapImpl;
 import org.apache.drill.exec.util.ImpersonationUtil;
+import org.apache.drill.exec.vector.NullableBitVector;
 import org.apache.drill.exec.vector.NullableBigIntVector;
 import org.apache.drill.exec.vector.NullableDateVector;
 import org.apache.drill.exec.vector.NullableDecimal18Vector;
@@ -477,6 +478,12 @@ public class ParquetGroupScan extends AbstractFileGroupScan {
     String f = Path.getPathWithoutSchemeAndAuthority(new Path(file)).toString();
     MinorType type = getTypeForColumn(column).getMinorType();
     switch (type) {
+      case BIT: {
+        NullableBitVector bitVector = (NullableBitVector) v;
+        Boolean value = (Boolean) partitionValueMap.get(f).get(column);
+        bitVector.getMutator().setSafe(index, value ? 1 : 0);
+        return;
+      }
       case INT: {
         NullableIntVector intVector = (NullableIntVector) v;
         Integer value = (Integer) partitionValueMap.get(f).get(column);


Mime
View raw message