From 7cc2c6431ee147c514d38c699be0af509a27095c Mon Sep 17 00:00:00 2001 From: Zhan Zhang Date: Wed, 13 May 2015 16:12:49 -0700 Subject: [PATCH] predicate fix --- .../main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala index 8e73f9181f08b..0a9924b139a48 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala @@ -99,6 +99,10 @@ private[sql] object OrcFilters extends Logging { Some(b1) } case p@IsNull(attribute: String) => { + val b1 = builder.isNull(attribute) + Some(b1) + } + case p@IsNotNull(attribute: String) => { val b1 = builder.startNot().isNull(attribute).end() Some(b1) }