Class FlinkChillPackageRegistrar
- java.lang.Object
-
- org.apache.flink.streaming.util.serialize.FlinkChillPackageRegistrar
-
- All Implemented Interfaces:
org.apache.flink.api.java.typeutils.runtime.kryo.ChillSerializerRegistrar
public class FlinkChillPackageRegistrar extends Object implements org.apache.flink.api.java.typeutils.runtime.kryo.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 Description FlinkChillPackageRegistrar()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetNextRegistrationId()voidregisterSerializers(com.esotericsoftware.kryo.Kryo kryo)
-
-
-
Method Detail
-
getNextRegistrationId
public int getNextRegistrationId()
- Specified by:
getNextRegistrationIdin interfaceorg.apache.flink.api.java.typeutils.runtime.kryo.ChillSerializerRegistrar
-
registerSerializers
public void registerSerializers(com.esotericsoftware.kryo.Kryo kryo)
- Specified by:
registerSerializersin interfaceorg.apache.flink.api.java.typeutils.runtime.kryo.ChillSerializerRegistrar
-
-