public class SparkRunnerKryoRegistrator extends java.lang.Object implements org.apache.spark.serializer.KryoRegistrator
KryoRegistrators for Beam's Spark runner needs and registering used class in spark translation for better serialization performance. This is not the default serialization mechanism.
To use it you must enable the Kryo based serializer using
spark.serializer with value
org.apache.spark.serializer.KryoSerializer and register this class via Spark
|Constructor and Description|