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.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)
-