@Internal public static interface TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>
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.
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<E> |
resolveSchemaCompatibilityViaRedirectingToNewSnapshotClass(TypeSerializerConfigSnapshot<E> deprecatedConfigSnapshot)
Resolve Schema Compatibility.
|
TypeSerializerSchemaCompatibility<E> resolveSchemaCompatibilityViaRedirectingToNewSnapshotClass(TypeSerializerConfigSnapshot<E> deprecatedConfigSnapshot)
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
.
deprecatedConfigSnapshot
- the not yet migrated config snapshot class.deprecatedConfigSnapshot
with this
serializer.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.