Skip to content

Commit 4171278

Browse files
committed
Revert "rm Jackson Scala module"
This reverts commit d7b4c56.
1 parent d7b4c56 commit 4171278

File tree

1 file changed

+8
-1
lines changed
  • arangodb-spark-commons/src/main/scala/org/apache/spark/sql/arangodb/commons

1 file changed

+8
-1
lines changed

arangodb-spark-commons/src/main/scala/org/apache/spark/sql/arangodb/commons/ArangoClient.scala

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ import com.arangodb.model.{AqlQueryOptions, CollectionCreateOptions}
88
import com.arangodb.velocypack.VPackSlice
99
import com.arangodb.velocystream.{Request, RequestType}
1010
import com.arangodb.{ArangoCursor, ArangoDB, ArangoDBException}
11+
import com.fasterxml.jackson.databind.ObjectMapper
12+
import com.fasterxml.jackson.module.scala.DefaultScalaModule
1113
import org.apache.spark.internal.Logging
1214
import org.apache.spark.sql.arangodb.commons.exceptions.ArangoDBMultiException
1315
import org.apache.spark.sql.arangodb.commons.filter.PushableFilter
@@ -30,7 +32,12 @@ class ArangoClient(options: ArangoDBConf) extends Logging {
3032

3133
lazy val arangoDB: ArangoDB = options.driverOptions
3234
.builder()
33-
.serializer(new ArangoJack())
35+
.serializer(new ArangoJack() {
36+
//noinspection ConvertExpressionToSAM
37+
configure(new ArangoJack.ConfigureFunction {
38+
override def configure(mapper: ObjectMapper): Unit = mapper.registerModule(DefaultScalaModule)
39+
})
40+
})
3441
.build()
3542

3643
def shutdown(): Unit = {

0 commit comments

Comments
 (0)