Interface ChillSerializerRegistrar


  • public interface ChillSerializerRegistrar
    Interface for flink-core to interact with the FlinkChillPackageRegistrar in flink-java.
    • 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