add test case

ISG-ICS · Aug 31, 2016 · 688bb6a · 688bb6a
1 parent 808835f
commit 688bb6a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/zion/src/main/scala/edu/uci/ics/cloudberry/zion/model/impl/QueryPlanner.scala b/zion/src/main/scala/edu/uci/ics/cloudberry/zion/model/impl/QueryPlanner.scala
@@ -57,7 +57,7 @@ class QueryPlanner {
 
         //TODO here is a very simple assumption that the schema is the same, what if the schema are different?
         val viewFilters = view.createQueryOpt.get.filter
-        val newFilter = query.filter.filterNot(qf => viewFilters.exists(vf => vf.covers(qf, source.schema.fieldMap(qf.fieldName).dataType)))
+        val newFilter = query.filter.filterNot(qf => viewFilters.exists(vf => qf.covers(vf, source.schema.fieldMap(qf.fieldName).dataType)))
         seqBuilder += query.copy(dataset = view.name, filter = newFilter)
         for (interval <- unCovered) {
           seqBuilder += query.setInterval(source.schema.timeField, interval)

diff --git a/zion/src/test/scala/edu/uci/ics/cloudberry/zion/model/impl/QueryPlannerTest.scala b/zion/src/test/scala/edu/uci/ics/cloudberry/zion/model/impl/QueryPlannerTest.scala
@@ -47,6 +47,12 @@ class QueryPlannerTest extends Specification {
       queries.size must_== 1
       queries.head must_== queryCount.copy(dataset = zikaFullYearViewInfo.name)
     }
+    "makePlan should omit the redundant filter from query if it covers view.createQuery" in {
+      val queryZika = Query(dataset = TwitterDataSet, filter = Seq(FilterStatement("text", None, Relation.contains, Seq("zika"))), groups = Some(group))
+      val (queries, _) = planner.makePlan(queryZika, sourceInfo, Seq(zikaFullYearViewInfo))
+      queries.size must_== 1
+      queries.head must_== Query(dataset = zikaFullYearViewInfo.name, groups = Some(group))
+    }
     "makePlan should ask the view and the source if view can not cover the query" in {
       val (queries, _) = planner.makePlan(queryCount, sourceInfo, Seq(zikaHalfYearViewInfo))
       queries.size must_== 2