From e9032786bacac06b54d106de939db9641d25fdc6 Mon Sep 17 00:00:00 2001 From: Bo Meng Date: Mon, 8 Jun 2015 15:25:33 -0700 Subject: [PATCH] set previous cpr to null at root level --- .../scala/org/apache/spark/sql/hbase/HBaseCustomFilter.scala | 5 +++++ 1 file changed, 5 insertions(+) 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 index 3ec7c50c3a12a..365f1e25a0598 100644 --- 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]))) {