Skip to content

Commit edba520

Browse files
anicolasppekrivokonmapr
authored andcommitted
Support for Java Types Filtering
- When writing application in Java, they types are not being pushed down since the Java types are not the same as Scala Types
1 parent 121abcd commit edba520

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

external/maprdb/src/main/scala/com/mapr/db/spark/sql/v2/SupportedFilterTypes.scala

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,21 @@ object SupportedFilterTypes {
66

77
private lazy val supportedTypes = List[Class[_]](
88
classOf[Double],
9+
classOf[java.lang.Double],
910
classOf[Float],
11+
classOf[java.lang.Float],
1012
classOf[Int],
13+
classOf[Integer],
1114
classOf[Long],
15+
classOf[java.lang.Long],
1216
classOf[Short],
17+
classOf[java.lang.Short],
1318
classOf[String],
1419
classOf[Timestamp],
1520
classOf[Boolean],
16-
classOf[Byte]
21+
classOf[java.lang.Boolean],
22+
classOf[Byte],
23+
classOf[java.lang.Byte]
1724
)
1825

1926
def isSupportedType(value: Any): Boolean = supportedTypes.contains(value.getClass)

0 commit comments

Comments
 (0)