Uses of Interface
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot

Packages that use TypeSerializerSnapshot

Package	Description
org.apache.flink.api.common.typeutils
org.apache.flink.api.common.typeutils.base
org.apache.flink.api.common.typeutils.base.array
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.api.java.typeutils.runtime.kryo
org.apache.flink.core.io

Uses of TypeSerializerSnapshot in org.apache.flink.api.common.typeutils

Classes in org.apache.flink.api.common.typeutils that implement TypeSerializerSnapshot

Modifier and Type	Class	Description
class	CompositeTypeSerializerSnapshot<T,S extends TypeSerializer<T>>	A CompositeTypeSerializerSnapshot is a convenient serializer snapshot class that can be used by simple serializers which 1) delegates its serialization to multiple nested serializers, and 2) may contain some extra static information that needs to be persisted as part of its snapshot.
class	GenericTypeSerializerSnapshot<T,S extends TypeSerializer>	Base TypeSerializerSnapshot for serializers for generic types.
class	SimpleTypeSerializerSnapshot<T>	A simple base class for TypeSerializerSnapshots, for serializers that have no parameters.
static class	SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessCheckingTypeSerializerSnapshot<T>

Methods in org.apache.flink.api.common.typeutils that return TypeSerializerSnapshot

Modifier and Type	Method	Description
TypeSerializerSnapshot<?>[]	CompositeTypeSerializerSnapshot.getNestedSerializerSnapshots()
TypeSerializerSnapshot<?>[]	NestedSerializersSnapshotDelegate.getNestedSerializerSnapshots()	Returns the snapshots of the nested serializers.
static <T> TypeSerializerSnapshot<T>	TypeSerializerSnapshotSerializationUtil.readAndInstantiateSnapshotClass(DataInputView in, ClassLoader cl)
static <T> TypeSerializerSnapshot<T>	TypeSerializerSnapshotSerializationUtil.readSerializerSnapshot(DataInputView in, ClassLoader userCodeClassLoader)	Reads from a data input view a TypeSerializerSnapshot that was previously written using {@link #writeSerializerSnapshot(DataOutputView, TypeSerializerSnapshot}.
static <T> TypeSerializerSnapshot<T>	TypeSerializerSnapshot.readVersionedSnapshot(DataInputView in, ClassLoader cl)	Reads a snapshot from the stream, performing resolving
static TypeSerializerSnapshot<?>[]	TypeSerializerUtils.snapshot(TypeSerializer<?>... originatingSerializers)	Takes snapshots of the given serializers.
TypeSerializerSnapshot<T>	SingleThreadAccessCheckingTypeSerializer.snapshotConfiguration()
abstract TypeSerializerSnapshot<T>	TypeSerializer.snapshotConfiguration()	Snapshots the configuration of this TypeSerializer.
TypeSerializerSnapshot<T>	UnloadableDummyTypeSerializer.snapshotConfiguration()
<U> TypeSerializerSnapshot<T>	LegacySerializerSnapshotTransformer.transformLegacySerializerSnapshot(TypeSerializerSnapshot<U> legacySnapshot)	Transform a TypeSerializerSnapshot that was previously associated with this TypeSerializer.

Methods in org.apache.flink.api.common.typeutils with parameters of type TypeSerializerSnapshot

Modifier and Type	Method	Description
static <T> CompositeTypeSerializerUtil.IntermediateCompatibilityResult<T>	CompositeTypeSerializerUtil.constructIntermediateCompatibilityResult(TypeSerializerSnapshot<?>[] newNestedSerializerSnapshots, TypeSerializerSnapshot<?>[] oldNestedSerializerSnapshots)	Constructs an CompositeTypeSerializerUtil.IntermediateCompatibilityResult with the given array of nested serializers and their corresponding serializer snapshots.
static <T> TypeSerializerSchemaCompatibility<T>	CompositeTypeSerializerUtil.delegateCompatibilityCheckToNewSnapshot(TypeSerializerSnapshot<T> legacySerializerSnapshot, CompositeTypeSerializerSnapshot<T,? extends TypeSerializer<T>> newCompositeSnapshot, TypeSerializerSnapshot<?>... legacyNestedSnapshots)	Delegates compatibility checks to a CompositeTypeSerializerSnapshot instance.
protected CompositeTypeSerializerSnapshot.OuterSchemaCompatibility	CompositeTypeSerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)	Checks the schema compatibility of the given old serializer snapshot based on the outer snapshot.
TypeSerializerSchemaCompatibility<T>	CompositeTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)
TypeSerializerSchemaCompatibility<T>	GenericTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)
TypeSerializerSchemaCompatibility<T>	SimpleTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)
default TypeSerializerSchemaCompatibility<T>	TypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)	Checks current serializer's compatibility to read data written by the prior serializer.
static void	CompositeTypeSerializerUtil.setNestedSerializersSnapshots(CompositeTypeSerializerSnapshot<?,?> compositeSnapshot, TypeSerializerSnapshot<?>... nestedSnapshots)	Overrides the existing nested serializer's snapshots with the provided nestedSnapshots.
<U> TypeSerializerSnapshot<T>	LegacySerializerSnapshotTransformer.transformLegacySerializerSnapshot(TypeSerializerSnapshot<U> legacySnapshot)	Transform a TypeSerializerSnapshot that was previously associated with this TypeSerializer.
static <T> void	TypeSerializerSnapshotSerializationUtil.writeSerializerSnapshot(DataOutputView out, TypeSerializerSnapshot<T> serializerSnapshot)	Writes a TypeSerializerSnapshot to the provided data output view.
static void	TypeSerializerSnapshot.writeVersionedSnapshot(DataOutputView out, TypeSerializerSnapshot<?> snapshot)	Writes the given snapshot to the out stream.

Uses of TypeSerializerSnapshot in org.apache.flink.api.common.typeutils.base

Classes in org.apache.flink.api.common.typeutils.base that implement TypeSerializerSnapshot

Modifier and Type	Class	Description
static class	BigDecSerializer.BigDecSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	BigIntSerializer.BigIntSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	BooleanSerializer.BooleanSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	BooleanValueSerializer.BooleanValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	ByteSerializer.ByteSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	ByteValueSerializer.ByteValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	CharSerializer.CharSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	CharValueSerializer.CharValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	DateSerializer.DateSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	DoubleSerializer.DoubleSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	DoubleValueSerializer.DoubleValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	EnumSerializer.EnumSerializerSnapshot<T extends Enum<T>>	TypeSerializerSnapshot for EnumSerializer.
static class	FloatSerializer.FloatSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	FloatValueSerializer.FloatValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
class	GenericArraySerializerConfigSnapshot<C>	Deprecated. this is deprecated and no longer used by the GenericArraySerializer.
class	GenericArraySerializerSnapshot<C>	Point-in-time configuration of a GenericArraySerializer.
static class	InstantSerializer.InstantSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	IntSerializer.IntSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	IntValueSerializer.IntValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
class	ListSerializerSnapshot<T>	Snapshot class for the ListSerializer.
static class	LocalDateSerializer.LocalDateSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	LocalDateTimeSerializer.LocalDateTimeSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	LocalTimeSerializer.LocalTimeSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	LongSerializer.LongSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	LongValueSerializer.LongValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
class	MapSerializerSnapshot<K,V>	Snapshot class for the MapSerializer.
static class	NullValueSerializer.NullValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	ShortSerializer.ShortSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	ShortValueSerializer.ShortValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	SqlDateSerializer.SqlDateSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	SqlTimeSerializer.SqlTimeSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	SqlTimestampSerializer.SqlTimestampSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	StringSerializer.StringSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	StringValueSerializer.StringValueSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	VoidSerializer.VoidSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.

Methods in org.apache.flink.api.common.typeutils.base that return TypeSerializerSnapshot

Modifier and Type	Method	Description
TypeSerializerSnapshot<K>	MapSerializerSnapshot.getKeySerializerSnapshot()
TypeSerializerSnapshot<?>[]	GenericArraySerializerConfigSnapshot.getNestedSerializerSnapshots()	Deprecated.
TypeSerializerSnapshot<BigDecimal>	BigDecSerializer.snapshotConfiguration()
TypeSerializerSnapshot<BigInteger>	BigIntSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Boolean>	BooleanSerializer.snapshotConfiguration()
TypeSerializerSnapshot<BooleanValue>	BooleanValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Byte>	ByteSerializer.snapshotConfiguration()
TypeSerializerSnapshot<ByteValue>	ByteValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Character>	CharSerializer.snapshotConfiguration()
TypeSerializerSnapshot<CharValue>	CharValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Date>	DateSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Double>	DoubleSerializer.snapshotConfiguration()
TypeSerializerSnapshot<DoubleValue>	DoubleValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Float>	FloatSerializer.snapshotConfiguration()
TypeSerializerSnapshot<FloatValue>	FloatValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<java.time.Instant>	InstantSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Integer>	IntSerializer.snapshotConfiguration()
TypeSerializerSnapshot<IntValue>	IntValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<List<T>>	ListSerializer.snapshotConfiguration()
TypeSerializerSnapshot<java.time.LocalDate>	LocalDateSerializer.snapshotConfiguration()
TypeSerializerSnapshot<java.time.LocalDateTime>	LocalDateTimeSerializer.snapshotConfiguration()
TypeSerializerSnapshot<java.time.LocalTime>	LocalTimeSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Long>	LongSerializer.snapshotConfiguration()
TypeSerializerSnapshot<LongValue>	LongValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Map<K,V>>	MapSerializer.snapshotConfiguration()
TypeSerializerSnapshot<NullValue>	NullValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Short>	ShortSerializer.snapshotConfiguration()
TypeSerializerSnapshot<ShortValue>	ShortValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Date>	SqlDateSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Time>	SqlTimeSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Timestamp>	SqlTimestampSerializer.snapshotConfiguration()
TypeSerializerSnapshot<String>	StringSerializer.snapshotConfiguration()
TypeSerializerSnapshot<StringValue>	StringValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Void>	VoidSerializer.snapshotConfiguration()

Methods in org.apache.flink.api.common.typeutils.base with parameters of type TypeSerializerSnapshot

Modifier and Type	Method	Description
protected CompositeTypeSerializerSnapshot.OuterSchemaCompatibility	GenericArraySerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot<C[]> oldSerializerSnapshot)
TypeSerializerSchemaCompatibility<T>	EnumSerializer.EnumSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)
TypeSerializerSchemaCompatibility<C[]>	GenericArraySerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<C[]> oldSerializerSnapshot)

Uses of TypeSerializerSnapshot in org.apache.flink.api.common.typeutils.base.array

Classes in org.apache.flink.api.common.typeutils.base.array that implement TypeSerializerSnapshot

Modifier and Type	Class	Description
static class	BooleanPrimitiveArraySerializer.BooleanPrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	BytePrimitiveArraySerializer.BytePrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	CharPrimitiveArraySerializer.CharPrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	DoublePrimitiveArraySerializer.DoublePrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	FloatPrimitiveArraySerializer.FloatPrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	IntPrimitiveArraySerializer.IntPrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	LongPrimitiveArraySerializer.LongPrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	ShortPrimitiveArraySerializer.ShortPrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
static class	StringArraySerializer.StringArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.

Methods in org.apache.flink.api.common.typeutils.base.array that return TypeSerializerSnapshot

Modifier and Type	Method	Description
TypeSerializerSnapshot<boolean[]>	BooleanPrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<byte[]>	BytePrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<char[]>	CharPrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<double[]>	DoublePrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<float[]>	FloatPrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<int[]>	IntPrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<long[]>	LongPrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<short[]>	ShortPrimitiveArraySerializer.snapshotConfiguration()
TypeSerializerSnapshot<String[]>	StringArraySerializer.snapshotConfiguration()

Uses of TypeSerializerSnapshot in org.apache.flink.api.java.typeutils.runtime

Classes in org.apache.flink.api.java.typeutils.runtime that implement TypeSerializerSnapshot

Modifier and Type	Class	Description
static class	CopyableValueSerializer.CopyableValueSerializerSnapshot<T extends CopyableValue<T>>	TypeSerializerSnapshot for the CopyableValueSerializer.
class	EitherSerializerSnapshot<L,R>	Deprecated. this snapshot class is no longer used by any serializers.
class	JavaEitherSerializerSnapshot<L,R>	Snapshot class for the EitherSerializer.
static class	NullableSerializer.NullableSerializerSnapshot<T>	Snapshot for serializers of nullable types, containing the snapshot of its original serializer.
class	PojoSerializerSnapshot<T>	Snapshot class for the PojoSerializer.
static class	RowSerializer.RowSerializerSnapshot	A TypeSerializerSnapshot for RowSerializer.
class	Tuple0SerializerSnapshot	A TypeSerializerSnapshot for Tuple0Serializer.
class	TupleSerializerSnapshot<T extends Tuple>	Snapshot of a tuple serializer's configuration.
static class	ValueSerializer.ValueSerializerSnapshot<T extends Value>	ValueSerializer snapshot class.

Methods in org.apache.flink.api.java.typeutils.runtime that return TypeSerializerSnapshot

Modifier and Type	Method	Description
TypeSerializerSnapshot<?>[]	EitherSerializerSnapshot.getNestedSerializerSnapshots()	Deprecated.
TypeSerializerSnapshot<T>	CopyableValueSerializer.snapshotConfiguration()
TypeSerializerSnapshot<T>	NullableSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Row>	RowSerializer.snapshotConfiguration()
TypeSerializerSnapshot<Tuple0>	Tuple0Serializer.snapshotConfiguration()
TypeSerializerSnapshot<T>	TupleSerializer.snapshotConfiguration()
TypeSerializerSnapshot<T>	ValueSerializer.snapshotConfiguration()

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type TypeSerializerSnapshot

Modifier and Type	Method	Description
protected CompositeTypeSerializerSnapshot.OuterSchemaCompatibility	NullableSerializer.NullableSerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)
protected CompositeTypeSerializerSnapshot.OuterSchemaCompatibility	RowSerializer.RowSerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot<Row> oldSerializerSnapshot)
TypeSerializerSchemaCompatibility<Either<L,R>>	JavaEitherSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<Either<L,R>> oldSerializerSnapshot)
TypeSerializerSchemaCompatibility<T>	PojoSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)

Uses of TypeSerializerSnapshot in org.apache.flink.api.java.typeutils.runtime.kryo

Classes in org.apache.flink.api.java.typeutils.runtime.kryo that implement TypeSerializerSnapshot

Modifier and Type	Class	Description
class	KryoSerializerSnapshot<T>	TypeSerializerSnapshot for KryoSerializer.

Methods in org.apache.flink.api.java.typeutils.runtime.kryo that return TypeSerializerSnapshot

Modifier and Type	Method	Description
TypeSerializerSnapshot<T>	KryoSerializer.snapshotConfiguration()

Methods in org.apache.flink.api.java.typeutils.runtime.kryo with parameters of type TypeSerializerSnapshot

Modifier and Type	Method	Description
TypeSerializerSchemaCompatibility<T>	KryoSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<T> oldSerializerSnapshot)

Uses of TypeSerializerSnapshot in org.apache.flink.core.io

Methods in org.apache.flink.core.io that return TypeSerializerSnapshot

Modifier and Type	Method	Description
TypeSerializerSnapshot<T>	SimpleVersionedSerializerTypeSerializerProxy.snapshotConfiguration()