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

Interface ChillSerializerRegistrar

All Known Implementing Classes:

FlinkChillPackageRegistrar

public interface ChillSerializerRegistrar

Interface for flink-core to interact with the FlinkChillPackageRegistrar in flink-java.

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.

Method Detail

registerSerializers

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

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

Parameters:

kryo - Kryo to register serializers with

getNextRegistrationId

int getNextRegistrationId()

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

Returns:

registration ID that should be used for the next serializer registration