class ScalaSomeSerializer extends Serializer[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.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ScalaSomeSerializer
- Serializer
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ScalaSomeSerializer()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def copy(arg0: Kryo, arg1: Some[_]): Some[_]
- Definition Classes
- Serializer
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def getAcceptsNull(): Boolean
- Definition Classes
- Serializer
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def isImmutable(): Boolean
- Definition Classes
- Serializer
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def read(kryo: Kryo, input: Input, type: Class[Some[_]]): Some[_]
- Definition Classes
- ScalaSomeSerializer → Serializer
- def setAcceptsNull(arg0: Boolean): Unit
- Definition Classes
- Serializer
- def setGenerics(arg0: Kryo, arg1: Array[Class[_ <: AnyRef]]): Unit
- Definition Classes
- Serializer
- def setImmutable(arg0: Boolean): Unit
- Definition Classes
- Serializer
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def write(kryo: Kryo, output: Output, obj: Some[_]): Unit
- Definition Classes
- ScalaSomeSerializer → Serializer
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)