Class 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 Detail

      • FlinkChillPackageRegistrar

        public FlinkChillPackageRegistrar()
    • Method Detail

      • getNextRegistrationId

        public int getNextRegistrationId()
        Specified by:
        getNextRegistrationId in interface org.apache.flink.api.java.typeutils.runtime.kryo.ChillSerializerRegistrar
      • registerSerializers

        public void registerSerializers​(com.esotericsoftware.kryo.Kryo kryo)
        Specified by:
        registerSerializers in interface org.apache.flink.api.java.typeutils.runtime.kryo.ChillSerializerRegistrar