diff options
author | Volodymyr Vysotskyi <vvovyk@gmail.com> | 2018-11-23 11:34:13 +0200 |
---|---|---|
committer | Volodymyr Vysotskyi <vvovyk@gmail.com> | 2018-11-26 16:08:29 +0200 |
commit | 99a3d76551d1a08958c7cd7670df189963fbc943 (patch) | |
tree | 5db50c194f770647da444b649f62b0e31bda8a8b /exec/java-exec/src/test/java/org | |
parent | d1a082cd11c79497449fda06189cd00d3510b2e9 (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.java | 9 |
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. ////////////////////////////////////////////////////////////////////////////////////////////////// |