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.
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, resolveSchemaCompatibility, restoreSerializer, writeOuterSnapshot, writeSnapshot
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
readVersionedSnapshot, 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–2020 The Apache Software Foundation. All rights reserved.