Package com.here.platform.data.client.flink.serializers

Class ScalaNilSerializer

java.lang.Object
com.esotericsoftware.kryo.Serializer<scala.collection.immutable.Nil$>
com.here.platform.data.client.flink.serializers.ScalaNilSerializer
public class ScalaNilSerializer extends com.esotericsoftware.kryo.Serializer<scala.collection.immutable.Nil$>
A dedicated serializer for the Scala Nil singleton.

In Apache Flink applications that utilize Scala libraries, particularly those involving the Scala List type and its singleton instance Nil, serialization issues may arise from Kryo's deserialization of Scala objects. By introducing a custom serializer specifically for the Nil object, such deserialization issues can be effectively solved.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ScalaNilSerializer()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.Nil
    read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends scala.collection.immutable.Nil$> type)
     
    void
    write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, scala.Nil obj)
     

    Methods inherited from class com.esotericsoftware.kryo.Serializer

    copy, getAcceptsNull, isImmutable, setAcceptsNull, setImmutable

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ScalaNilSerializer

      public ScalaNilSerializer()

  • Method Details

    • read

      public scala.Nil read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends scala.collection.immutable.Nil$> type)
      Specified by:
      read in class com.esotericsoftware.kryo.Serializer<scala.collection.immutable.Nil$>

    • write

      public void write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, scala.Nil obj)
      Specified by:
      write in class com.esotericsoftware.kryo.Serializer<scala.collection.immutable.Nil$>