aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/test/java/org
diff options
context:
space:
mode:
authorVolodymyr Vysotskyi <vvovyk@gmail.com>2018-11-23 11:34:13 +0200
committerVolodymyr Vysotskyi <vvovyk@gmail.com>2018-11-26 16:08:29 +0200
commit99a3d76551d1a08958c7cd7670df189963fbc943 (patch)
tree5db50c194f770647da444b649f62b0e31bda8a8b /exec/java-exec/src/test/java/org
parentd1a082cd11c79497449fda06189cd00d3510b2e9 (diff)
DRILL-6865: Filter is not removed from the plan when parquet table fully matches the filter
closes #1552
Diffstat (limited to 'exec/java-exec/src/test/java/org')
-rw-r--r--exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetFilterPushDown.java9
1 files changed, 9 insertions, 0 deletions
diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetFilterPushDown.java b/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetFilterPushDown.java
index ccc1480d9..80b06d916 100644
--- a/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetFilterPushDown.java
+++ b/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetFilterPushDown.java
@@ -649,6 +649,15 @@ public class TestParquetFilterPushDown extends PlanTestBase {
assertEquals(RowsMatch.ALL, isNotFalse.matches(re));
}
+ @Test
+ public void testParquetSingleRowGroupFilterRemoving() throws Exception {
+ test("create table dfs.tmp.`singleRowGroupTable` as select * from cp.`tpch/nation.parquet`");
+
+ String query = "select * from dfs.tmp.`singleRowGroupTable` where n_nationkey > -1";
+
+ testParquetFilterPruning(query, 25, 1, new String[]{"Filter\\("});
+ }
+
//////////////////////////////////////////////////////////////////////////////////////////////////
// Some test helper functions.
//////////////////////////////////////////////////////////////////////////////////////////////////