org.apache.flink.api.common.typeutils

Interface TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>

All Known Implementing Classes:

ArrayListSerializer, TtlStateFactory.TtlSerializer, Tuple0Serializer, TupleSerializer

Enclosing class:

TypeSerializerConfigSnapshot<T>

@Internal
public static interface TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>

This interface assists with the migration path to the new serialization abstraction.

This interface can be used for cases where the `ensureCompatibility` method cannot be removed. Implementing this interface by your TypeSerializer would allow it to "redirect" the compatibility check to the corresponding {code TypeSerializerSnapshot} class.

Please note that if it is possible to directly override TypeSerializerConfigSnapshot.resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<T>) and preform the redirection logic there, then that is the preferred way. This interface is useful for cases where there is not enough information, and the new serializer should assist with the redirection.

Method Summary

Modifier and Type	Method and Description
TypeSerializerSchemaCompatibility<E>	resolveSchemaCompatibilityViaRedirectingToNewSnapshotClass(TypeSerializerConfigSnapshot<E> deprecatedConfigSnapshot) Resolve Schema Compatibility.

Method Detail

resolveSchemaCompatibilityViaRedirectingToNewSnapshotClass

TypeSerializerSchemaCompatibility<E> resolveSchemaCompatibilityViaRedirectingToNewSnapshotClass(TypeSerializerConfigSnapshot<E> deprecatedConfigSnapshot)

Resolve Schema Compatibility.

Given an instance of a TypeSerializerConfigSnapshot this method should redirect the compatibility check to the new TypeSerializerSnapshot class along with the relevant information as present in the given deprecatedConfigSnapshot.

Parameters:

deprecatedConfigSnapshot - the not yet migrated config snapshot class.

Returns:

the compatibility result of the deprecatedConfigSnapshot with this serializer.