org.apache.flink.api.java.typeutils.runtime.kryo

Class FlinkChillPackageRegistrar

java.lang.Object

org.apache.flink.api.java.typeutils.runtime.kryo.FlinkChillPackageRegistrar

All Implemented Interfaces:

ChillSerializerRegistrar

public class FlinkChillPackageRegistrar
extends Object
implements ChillSerializerRegistrar

Registers all chill serializers used for Java types.

All registrations use a hard-coded ID which were determined at commit 18f176ce86900fd4e932c73f3d138912355c6880.

Constructor Summary

Constructors

Constructor and Description
FlinkChillPackageRegistrar()

Method Summary

Modifier and Type	Method and Description
int	getNextRegistrationId() Returns the registration ID that immediately follows the last registered serializer.
void	registerSerializers(com.esotericsoftware.kryo.Kryo kryo) Registers all serializers with the given Kryo.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkChillPackageRegistrar

public FlinkChillPackageRegistrar()

Method Detail

getNextRegistrationId

public int getNextRegistrationId()

Description copied from interface: ChillSerializerRegistrar

Returns the registration ID that immediately follows the last registered serializer.

Specified by:

getNextRegistrationId in interface ChillSerializerRegistrar

Returns:

registration ID that should be used for the next serializer registration

registerSerializers

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

Description copied from interface: ChillSerializerRegistrar

Registers all serializers with the given Kryo. All serializers are registered with specific IDs as a continuous block.

Specified by:

registerSerializers in interface ChillSerializerRegistrar

Parameters:

kryo - Kryo to register serializers with