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

Class ScalaSomeSerializer

java.lang.Object
com.esotericsoftware.kryo.Serializer<scala.Some<?>>
com.here.platform.data.client.flink.serializers.ScalaSomeSerializer
public class ScalaSomeSerializer extends com.esotericsoftware.kryo.Serializer<scala.Some<?>>
A dedicated serializer for the Scala Some singleton.

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    ScalaSomeSerializer()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.Some<?>
    read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<? extends scala.Some<?>> type)
     
    void
    write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, scala.Some<?> 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

    • ScalaSomeSerializer

      public ScalaSomeSerializer()

  • Method Details

    • read

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

    • write

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