[SPARK-508] MapR-DB OJAI Connector for Spark isNull condition returns…

… incorrect result (apache#475) (apache#480)
arjunshroff · Sep 19, 2019 · a3852ef · a3852ef
1 parent 9a89ac8
commit a3852ef
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/external/maprdb/src/main/scala/com/mapr/db/spark/sql/MapRDBRelation.scala b/external/maprdb/src/main/scala/com/mapr/db/spark/sql/MapRDBRelation.scala
@@ -144,11 +144,11 @@ private[spark] case class MapRDBRelation(
         if (!inNot) getPredicate(fld, QueryCondition.Op.LESS_OR_EQUAL, value)
         else getPredicate(fld, QueryCondition.Op.GREATER, value)
       case IsNull(fld) =>
-        if (!inNot) field(fld) notexists
-        else field(fld) exists
+        if (!inNot) field(fld).typeof("NULL")
+        else field(fld).nottypeof("NULL")
       case IsNotNull(fld) =>
-        if (!inNot) field(fld) exists
-        else field(fld) notexists
+        if (!inNot) field(fld).nottypeof("NULL")
+        else field(fld).typeof("NULL")
       case And(leftFilter, rightFilter) =>
         if (!inNot) {
           convertToCondition(Array(leftFilter), inNot) and