Modifier and Type | Method and 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.incompatible()
Returns a result that indicates there is no possible way for the new serializer to be use-able.
|
<T> TypeSerializerSchemaCompatibility<T> |
CompositeSerializerSnapshot.resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?> outerCompatibility,
TypeSerializer<?>... newNestedSerializers)
Resolves the compatibility of the nested serializer snapshots with the nested
serializers of the new outer serializer.
|
TypeSerializerSchemaCompatibility<T> |
TypeSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
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.
|
TypeSerializerSchemaCompatibility<T> |
BackwardsCompatibleSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
Modifier and Type | Method and Description |
---|---|
<T> TypeSerializerSchemaCompatibility<T> |
CompositeSerializerSnapshot.resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?> outerCompatibility,
TypeSerializer<?>... newNestedSerializers)
Resolves the compatibility of the nested serializer snapshots with the nested
serializers of the new outer serializer.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<C[]> |
GenericArraySerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<C[]> newSerializer) |
TypeSerializerSchemaCompatibility<C> |
CollectionSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<C> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<List<T>> |
ListSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<List<T>> newSerializer) |
TypeSerializerSchemaCompatibility<Map<K,V>> |
MapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<Map<K,V>> newSerializer) |
TypeSerializerSchemaCompatibility<Map<K,V>> |
MapSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Map<K,V>> newSerializer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<Either<L,R>> |
EitherSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer) |
TypeSerializerSchemaCompatibility<Either<L,R>> |
EitherSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<scala.util.Either<L,R>> |
ScalaEitherSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<scala.util.Either<L,R>> newSerializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<Lockable<E>> |
LockableTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<Lockable<E>> newSerializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<T> |
AvroSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
Modifier and Type | Method and Description |
---|---|
abstract TypeSerializerSchemaCompatibility<T> |
StateSerializerProvider.registerNewSerializerForRestoredState(TypeSerializer<T> newSerializer)
For restored state, register a new serializer that potentially has a new serialization schema.
|
TypeSerializerSchemaCompatibility<ArrayList<T>> |
ArrayListSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<ArrayList<T>> newSerializer) |
TypeSerializerSchemaCompatibility<T> |
RegisteredPriorityQueueStateBackendMetaInfo.updateElementSerializer(TypeSerializer<T> newElementSerializer) |
TypeSerializerSchemaCompatibility<K> |
RegisteredBroadcastStateBackendMetaInfo.updateKeySerializer(TypeSerializer<K> newKeySerializer) |
TypeSerializerSchemaCompatibility<N> |
RegisteredKeyValueStateBackendMetaInfo.updateNamespaceSerializer(TypeSerializer<N> newNamespaceSerializer) |
TypeSerializerSchemaCompatibility<S> |
RegisteredOperatorStateBackendMetaInfo.updatePartitionStateSerializer(TypeSerializer<S> newPartitionStateSerializer) |
TypeSerializerSchemaCompatibility<S> |
RegisteredKeyValueStateBackendMetaInfo.updateStateSerializer(TypeSerializer<S> newStateSerializer) |
TypeSerializerSchemaCompatibility<V> |
RegisteredBroadcastStateBackendMetaInfo.updateValueSerializer(TypeSerializer<V> newValueSerializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<org.apache.flink.table.api.dataview.ListView<T>> |
ListViewSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<org.apache.flink.table.api.dataview.ListView<T>> newSerializer) |
TypeSerializerSchemaCompatibility<org.apache.flink.table.api.dataview.MapView<K,V>> |
MapViewSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<org.apache.flink.table.api.dataview.MapView<K,V>> newSerializer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.