Uses of Class
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility
-
-
Uses of TypeSerializerSchemaCompatibility in org.apache.flink.api.common.typeutils
Methods in org.apache.flink.api.common.typeutils that return TypeSerializerSchemaCompatibility Modifier and Type Method Description static <T> TypeSerializerSchemaCompatibility<T>TypeSerializerSchemaCompatibility. compatibleAfterMigration()Returns a result that indicates that the new serializer can be used after migrating the written bytes, i.e. reading it with the old serializer and then writing it again with the new serializer.static <T> TypeSerializerSchemaCompatibility<T>TypeSerializerSchemaCompatibility. compatibleAsIs()Returns a result that indicates that the new serializer is compatible and no migration is required.static <T> TypeSerializerSchemaCompatibility<T>TypeSerializerSchemaCompatibility. compatibleWithReconfiguredSerializer(TypeSerializer<T> reconfiguredSerializer)Returns a result that indicates a reconfigured version of the new serializer is compatible, and should be used instead of the original new serializer.static <T> TypeSerializerSchemaCompatibility<T>CompositeTypeSerializerUtil. delegateCompatibilityCheckToNewSnapshot(TypeSerializer<T> newSerializer, CompositeTypeSerializerSnapshot<T,? extends TypeSerializer> newCompositeSnapshot, TypeSerializerSnapshot<?>... legacyNestedSnapshots)Delegates compatibility checks to aCompositeTypeSerializerSnapshotinstance.TypeSerializerSchemaCompatibility<T>CompositeTypeSerializerUtil.IntermediateCompatibilityResult. getFinalResult()static <T> TypeSerializerSchemaCompatibility<T>TypeSerializerSchemaCompatibility. incompatible()Returns a result that indicates there is no possible way for the new serializer to be use-able.<T> TypeSerializerSchemaCompatibility<T>NestedSerializersSnapshotDelegate. resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?> outerCompatibility, TypeSerializer<?>... newNestedSerializers)Deprecated.this no method will be removed in the future.TypeSerializerSchemaCompatibility<T>CompositeTypeSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<T> newSerializer)TypeSerializerSchemaCompatibility<T>GenericTypeSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<T> newSerializer)TypeSerializerSchemaCompatibility<T>SimpleTypeSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<T> newSerializer)TypeSerializerSchemaCompatibility<T>TypeSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<T> newSerializer)Checks a new serializer's compatibility to read data written by the prior serializer.Methods in org.apache.flink.api.common.typeutils with parameters of type TypeSerializerSchemaCompatibility Modifier and Type Method Description <T> TypeSerializerSchemaCompatibility<T>NestedSerializersSnapshotDelegate. resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?> outerCompatibility, TypeSerializer<?>... newNestedSerializers)Deprecated.this no method will be removed in the future. -
Uses of TypeSerializerSchemaCompatibility in org.apache.flink.api.common.typeutils.base
Methods in org.apache.flink.api.common.typeutils.base that return TypeSerializerSchemaCompatibility Modifier and Type Method Description TypeSerializerSchemaCompatibility<T>EnumSerializer.EnumSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<T> newSerializer)TypeSerializerSchemaCompatibility<C[]>GenericArraySerializerConfigSnapshot. resolveSchemaCompatibility(TypeSerializer<C[]> newSerializer)Deprecated. -
Uses of TypeSerializerSchemaCompatibility in org.apache.flink.api.java.typeutils.runtime
Methods in org.apache.flink.api.java.typeutils.runtime that return TypeSerializerSchemaCompatibility Modifier and Type Method Description TypeSerializerSchemaCompatibility<Either<L,R>>EitherSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer)Deprecated.TypeSerializerSchemaCompatibility<T>PojoSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<T> newSerializer) -
Uses of TypeSerializerSchemaCompatibility in org.apache.flink.api.java.typeutils.runtime.kryo
Methods in org.apache.flink.api.java.typeutils.runtime.kryo that return TypeSerializerSchemaCompatibility Modifier and Type Method Description TypeSerializerSchemaCompatibility<T>KryoSerializerSnapshot. resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
-