KryoSerializer takes the following to be created:
KryoSerializer is created when:
SparkConfis requested to registerKryoClasses
SerializerSupport(Spark SQL) is requested for a SerializerInstance
useUnsafe is used when
KryoSerializer is requested to create the following:
Creating New SerializerInstance¶
newInstance is part of the Serializer abstraction.
newKryoOutput is used when:
KryoSerializerInstanceis requested for the output
newKryo is used when:
KryoSerializer creates a
KryoFactory lazily (on demand and once only) for internalPool.
KryoSerializer creates a custom
KryoPool lazily (on demand and once only).
KryoPool is used when:
supportsRelocationOfSerializedObjects is part of the Serializer abstraction.