set previous cpr to null at root level

Huawei-Spark · Jun 8, 2015 · e903278 · e903278
1 parent c8ed695
commit e903278
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/sql/hbase/src/main/scala/org/apache/spark/sql/hbase/HBaseCustomFilter.scala b/sql/hbase/src/main/scala/org/apache/spark/sql/hbase/HBaseCustomFilter.scala
@@ -301,6 +301,11 @@ private[hbase] class HBaseCustomFilter extends FilterBase with Writable {
       val start: Option[T] = cprs(result).start
       val startInclusive: Boolean = cprs(result).startInclusive
       node.currentNodeIndex = result
+      if (currentNode == root && currentNode.currentNodeIndex > 0) {
+        for (i <- 0 to root.currentNodeIndex - 1) {
+          root.children(i) == null
+        }
+      }
       if (start.isEmpty ||
         (startInclusive && ordering.gteq(input.asInstanceOf[t], start.get.asInstanceOf[t])) ||
         (!startInclusive && ordering.gt(input.asInstanceOf[t], start.get.asInstanceOf[t]))) {