org.apache.flink.api.scala.typeutils

Class ScalaEitherSerializerSnapshot<L,R>

java.lang.Object

org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot<scala.util.Either<L,R>,org.apache.flink.api.scala.typeutils.EitherSerializer<L,R>>

org.apache.flink.api.scala.typeutils.ScalaEitherSerializerSnapshot<L,R>

All Implemented Interfaces:

TypeSerializerSnapshot<scala.util.Either<L,R>>

public class ScalaEitherSerializerSnapshot<L,R>
extends CompositeTypeSerializerSnapshot<scala.util.Either<L,R>,org.apache.flink.api.scala.typeutils.EitherSerializer<L,R>>

Configuration snapshot for serializers of Scala's Either type, containing configuration snapshots of the Left and Right serializers.

Constructor Summary

Constructors

Constructor and Description
ScalaEitherSerializerSnapshot() Constructor for read instantiation.
ScalaEitherSerializerSnapshot(org.apache.flink.api.scala.typeutils.EitherSerializer<L,R> eitherSerializer) Constructor to create the snapshot for writing.

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.api.scala.typeutils.EitherSerializer<L,R>	createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) Creates an instance of the outer serializer with a given array of its nested serializers.
int	getCurrentOuterSnapshotVersion() Returns the version of the current outer snapshot's written binary format.
protected TypeSerializer<?>[]	getNestedSerializers(org.apache.flink.api.scala.typeutils.EitherSerializer<L,R> outerSerializer) Gets the nested serializers from the outer serializer.

Methods inherited from class org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot

getCurrentVersion, isOuterSnapshotCompatible, readOuterSnapshot, readSnapshot, resolveSchemaCompatibility, restoreSerializer, writeOuterSnapshot, writeSnapshot

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot

readVersionedSnapshot, writeVersionedSnapshot

Constructor Detail

ScalaEitherSerializerSnapshot

public ScalaEitherSerializerSnapshot()

Constructor for read instantiation.

ScalaEitherSerializerSnapshot

public ScalaEitherSerializerSnapshot(org.apache.flink.api.scala.typeutils.EitherSerializer<L,R> eitherSerializer)

Constructor to create the snapshot for writing.

Method Detail

getCurrentOuterSnapshotVersion

public int getCurrentOuterSnapshotVersion()

Description copied from class: CompositeTypeSerializerSnapshot

Returns the version of the current outer snapshot's written binary format.

Specified by:

getCurrentOuterSnapshotVersion in class CompositeTypeSerializerSnapshot<scala.util.Either<L,R>,org.apache.flink.api.scala.typeutils.EitherSerializer<L,R>>

Returns:

the version of the current outer snapshot's written binary format.

createOuterSerializerWithNestedSerializers

protected org.apache.flink.api.scala.typeutils.EitherSerializer<L,R> createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)

Description copied from class: CompositeTypeSerializerSnapshot

Creates an instance of the outer serializer with a given array of its nested serializers.

Specified by:

createOuterSerializerWithNestedSerializers in class CompositeTypeSerializerSnapshot<scala.util.Either<L,R>,org.apache.flink.api.scala.typeutils.EitherSerializer<L,R>>

Parameters:

nestedSerializers - array of nested serializers to create the outer serializer with.

Returns:

an instance of the outer serializer.

getNestedSerializers

protected TypeSerializer<?>[] getNestedSerializers(org.apache.flink.api.scala.typeutils.EitherSerializer<L,R> outerSerializer)

Description copied from class: CompositeTypeSerializerSnapshot

Gets the nested serializers from the outer serializer.

Specified by:

getNestedSerializers in class CompositeTypeSerializerSnapshot<scala.util.Either<L,R>,org.apache.flink.api.scala.typeutils.EitherSerializer<L,R>>

Parameters:

outerSerializer - the outer serializer.

Returns:

the nested serializers.