uni.bielefeld.cmg.reflexiv.serializer

Class SparkKryoRegistrator

java.lang.Object

uni.bielefeld.cmg.reflexiv.serializer.SparkKryoRegistrator

All Implemented Interfaces:

org.apache.spark.serializer.KryoRegistrator

public class SparkKryoRegistrator
extends java.lang.Object
implements org.apache.spark.serializer.KryoRegistrator

An class used to register all classes for Spark kryo serializer.

See Also:

Constructor Summary

Constructors

Constructor and Description
SparkKryoRegistrator() A constructor that construct an object of SparkKryoRegistrator class.

Method Summary

Methods

Modifier and Type	Method and Description
void	registerClasses(com.esotericsoftware.kryo.Kryo kryo) This method registers all classes that are going to be serialized by kryo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkKryoRegistrator

public SparkKryoRegistrator()

A constructor that construct an object of SparkKryoRegistrator class. No constructor option needed.

Method Detail

registerClasses

public void registerClasses(com.esotericsoftware.kryo.Kryo kryo)

This method registers all classes that are going to be serialized by kryo

Specified by:

registerClasses in interface org.apache.spark.serializer.KryoRegistrator

Parameters:

kryo - Kryo.