January 2019
Beginner to intermediate
154 pages
4h 31m
English
Encoders can be created based on Java and Kryo serializers. Encoder factory objects are available in the org.apache.spark.sql package:
import org.apache.spark.sql.Encoders// Normal Encoderscala> Encoders.LONGres1: org.apache.spark.sql.Encoder[Long] = class[value[0]: bigint]// Kryo and Java Serialization Encoderscase class Sales(id: String, firstname: String, product_id: Boolean)scala> Encoders.kryo[Sales]res3: org.apache.spark.sql.Encoder[Sales] = class[value[0]: binary]scala> Encoders.javaSerialization[Sales]res5: org.apache.spark.sql.Encoder[Sales] = class[value[0]: binary]// Scala tuple encodersscala> Encoders.tuple(Encoders.scalaLong, Encoders.STRING, Encoders.scalaBoolean)res9: org.apache.spark.sql.Encoder[(Long, ...
Read now
Unlock full access