HBASE-15825 Fix the null pointer in DynamicLogicExpressionSuite (Zhan Zhang)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/084b036c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/084b036c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/084b036c Branch: refs/heads/HBASE-14850 Commit: 084b036cb2abc19d13262ff8d5e2ef2f451e4bf3 Parents: e0aff10 Author: tedyu <yuzhih...@gmail.com> Authored: Mon May 16 09:04:50 2016 -0700 Committer: tedyu <yuzhih...@gmail.com> Committed: Mon May 16 09:04:50 2016 -0700 ---------------------------------------------------------------------- .../hbase/spark/DynamicLogicExpressionSuite.scala | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/084b036c/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/DynamicLogicExpressionSuite.scala ---------------------------------------------------------------------- diff --git a/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/DynamicLogicExpressionSuite.scala b/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/DynamicLogicExpressionSuite.scala index ff4201c..b9c15ce 100644 --- a/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/DynamicLogicExpressionSuite.scala +++ b/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/DynamicLogicExpressionSuite.scala @@ -32,7 +32,9 @@ BeforeAndAfterEach with BeforeAndAfterAll with Logging { test("Basic And Test") { val leftLogic = new LessThanLogicExpression("Col1", 0) + leftLogic.setEncoder(encoder) val rightLogic = new GreaterThanLogicExpression("Col1", 1) + rightLogic.setEncoder(encoder) val andLogic = new AndLogicExpression(leftLogic, rightLogic) val columnToCurrentRowValueMap = new util.HashMap[String, ByteArrayComparable]() @@ -72,7 +74,9 @@ BeforeAndAfterEach with BeforeAndAfterAll with Logging { test("Basic OR Test") { val leftLogic = new LessThanLogicExpression("Col1", 0) + leftLogic.setEncoder(encoder) val rightLogic = new GreaterThanLogicExpression("Col1", 1) + rightLogic.setEncoder(encoder) val OrLogic = new OrLogicExpression(leftLogic, rightLogic) val columnToCurrentRowValueMap = new util.HashMap[String, ByteArrayComparable]() @@ -119,9 +123,13 @@ BeforeAndAfterEach with BeforeAndAfterAll with Logging { test("Basic Command Test") { val greaterLogic = new GreaterThanLogicExpression("Col1", 0) + greaterLogic.setEncoder(encoder) val greaterAndEqualLogic = new GreaterThanOrEqualLogicExpression("Col1", 0) + greaterAndEqualLogic.setEncoder(encoder) val lessLogic = new LessThanLogicExpression("Col1", 0) + lessLogic.setEncoder(encoder) val lessAndEqualLogic = new LessThanOrEqualLogicExpression("Col1", 0) + lessAndEqualLogic.setEncoder(encoder) val equalLogic = new EqualLogicExpression("Col1", 0, false) val notEqualLogic = new EqualLogicExpression("Col1", 0, true) val passThrough = new PassThroughLogicExpression @@ -192,7 +200,9 @@ BeforeAndAfterEach with BeforeAndAfterAll with Logging { test("Double Type") { val leftLogic = new LessThanLogicExpression("Col1", 0) + leftLogic.setEncoder(encoder) val rightLogic = new GreaterThanLogicExpression("Col1", 1) + rightLogic.setEncoder(encoder) val andLogic = new AndLogicExpression(leftLogic, rightLogic) val columnToCurrentRowValueMap = new util.HashMap[String, ByteArrayComparable]() @@ -231,7 +241,9 @@ BeforeAndAfterEach with BeforeAndAfterAll with Logging { test("Float Type") { val leftLogic = new LessThanLogicExpression("Col1", 0) + leftLogic.setEncoder(encoder) val rightLogic = new GreaterThanLogicExpression("Col1", 1) + rightLogic.setEncoder(encoder) val andLogic = new AndLogicExpression(leftLogic, rightLogic) val columnToCurrentRowValueMap = new util.HashMap[String, ByteArrayComparable]() @@ -270,7 +282,9 @@ BeforeAndAfterEach with BeforeAndAfterAll with Logging { test("String Type") { val leftLogic = new LessThanLogicExpression("Col1", 0) + leftLogic.setEncoder(encoder) val rightLogic = new GreaterThanLogicExpression("Col1", 1) + rightLogic.setEncoder(encoder) val andLogic = new AndLogicExpression(leftLogic, rightLogic) val columnToCurrentRowValueMap = new util.HashMap[String, ByteArrayComparable]() @@ -309,7 +323,9 @@ BeforeAndAfterEach with BeforeAndAfterAll with Logging { test("Boolean Type") { val leftLogic = new LessThanLogicExpression("Col1", 0) + leftLogic.setEncoder(encoder) val rightLogic = new GreaterThanLogicExpression("Col1", 1) + rightLogic.setEncoder(encoder) val columnToCurrentRowValueMap = new util.HashMap[String, ByteArrayComparable]()
