public class ScalaTrySerializerSnapshot<E> extends CompositeTypeSerializerSnapshot<scala.util.Try<E>,org.apache.flink.api.scala.typeutils.TrySerializer<E>>
TypeSerializerSnapshot
for the Scala TrySerializer
.
This configuration snapshot class is implemented in Java because Scala does not allow calling different base class constructors from subclasses, while we need that for the default empty constructor.
CompositeTypeSerializerSnapshot.OuterSchemaCompatibility
Constructor and Description |
---|
ScalaTrySerializerSnapshot()
This empty nullary constructor is required for deserializing the configuration.
|
ScalaTrySerializerSnapshot(org.apache.flink.api.scala.typeutils.TrySerializer<E> trySerializer) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.api.scala.typeutils.TrySerializer<E> |
createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
Creates an instance of the outer serializer with a given array of its nested serializers.
|
protected int |
getCurrentOuterSnapshotVersion()
Returns the version of the current outer snapshot's written binary format.
|
protected TypeSerializer<?>[] |
getNestedSerializers(org.apache.flink.api.scala.typeutils.TrySerializer<E> outerSerializer)
Gets the nested serializers from the outer serializer.
|
getCurrentVersion, getNestedSerializerSnapshots, isOuterSnapshotCompatible, readOuterSnapshot, readSnapshot, resolveOuterSchemaCompatibility, resolveOuterSchemaCompatibility, resolveSchemaCompatibility, restoreSerializer, writeOuterSnapshot, writeSnapshot
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
readVersionedSnapshot, resolveSchemaCompatibility, writeVersionedSnapshot
public ScalaTrySerializerSnapshot()
public ScalaTrySerializerSnapshot(org.apache.flink.api.scala.typeutils.TrySerializer<E> trySerializer)
protected int getCurrentOuterSnapshotVersion()
CompositeTypeSerializerSnapshot
getCurrentOuterSnapshotVersion
in class CompositeTypeSerializerSnapshot<scala.util.Try<E>,org.apache.flink.api.scala.typeutils.TrySerializer<E>>
protected TypeSerializer<?>[] getNestedSerializers(org.apache.flink.api.scala.typeutils.TrySerializer<E> outerSerializer)
CompositeTypeSerializerSnapshot
getNestedSerializers
in class CompositeTypeSerializerSnapshot<scala.util.Try<E>,org.apache.flink.api.scala.typeutils.TrySerializer<E>>
outerSerializer
- the outer serializer.protected org.apache.flink.api.scala.typeutils.TrySerializer<E> createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
CompositeTypeSerializerSnapshot
createOuterSerializerWithNestedSerializers
in class CompositeTypeSerializerSnapshot<scala.util.Try<E>,org.apache.flink.api.scala.typeutils.TrySerializer<E>>
nestedSerializers
- array of nested serializers to create the outer serializer with.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.