|
Change Parameter Type keySerializerConfigSnapshot : TypeSerializerConfigSnapshot to keySerializerConfigSnapshot : TypeSerializerSnapshot<K> in method public setKeySerializerConfigSnapshot(keySerializerConfigSnapshot TypeSerializerSnapshot<K>) : void in class org.apache.flink.streaming.api.operators.InternalTimersSnapshot |
From |
To |
|
Change Parameter Type registeredSubclassesToSerializerConfigSnapshots : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to registeredSubclassesToSerializerConfigSnapshots : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public PojoSerializerConfigSnapshot(pojoType Class<T>, fieldToSerializerConfigSnapshot LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, registeredSubclassesToSerializerConfigSnapshots LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, nonRegisteredSubclassesToSerializerConfigSnapshots HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, ignoreTypeSerializerSerialization boolean) in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Parameter Type namespaceSerializerConfigSnapshot : TypeSerializerConfigSnapshot to namespaceSerializerConfigSnapshot : TypeSerializerSnapshot<N> in method public setNamespaceSerializerConfigSnapshot(namespaceSerializerConfigSnapshot TypeSerializerSnapshot<N>) : void in class org.apache.flink.streaming.api.operators.InternalTimersSnapshot |
From |
To |
|
Change Parameter Type namespaceSerializerConfigSnapshot : TypeSerializerConfigSnapshot to namespaceSerializerConfigSnapshot : TypeSerializerSnapshot<N> in method public InternalTimersSnapshot(keySerializer TypeSerializer<K>, keySerializerConfigSnapshot TypeSerializerSnapshot<K>, namespaceSerializer TypeSerializer<N>, namespaceSerializerConfigSnapshot TypeSerializerSnapshot<N>, eventTimeTimers Set<TimerHeapInternalTimer<K,N>>, processingTimeTimers Set<TimerHeapInternalTimer<K,N>>) in class org.apache.flink.streaming.api.operators.InternalTimersSnapshot |
From |
To |
|
Change Parameter Type fieldToSerializerConfigSnapshot : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to fieldToSerializerConfigSnapshot : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public PojoSerializerConfigSnapshot(pojoType Class<T>, fieldToSerializerConfigSnapshot LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, registeredSubclassesToSerializerConfigSnapshots LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, nonRegisteredSubclassesToSerializerConfigSnapshots HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, ignoreTypeSerializerSerialization boolean) in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Parameter Type serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public writeSerializersAndConfigsWithResilience(out DataOutputView, serializersAndConfigs List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>) : void in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtil |
From |
To |
|
Change Parameter Type serializerConfigSnapshots : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshots : Map<String,TypeSerializerSnapshot<?>> in method public StateMetaInfoSnapshot(name String, backendStateType BackendStateType, options Map<String,String>, serializerConfigSnapshots Map<String,TypeSerializerSnapshot<?>>) in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot |
From |
To |
|
Change Parameter Type nonRegisteredSubclassesToSerializerConfigSnapshots : HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to nonRegisteredSubclassesToSerializerConfigSnapshots : HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public PojoSerializerConfigSnapshot(pojoType Class<T>, fieldToSerializerConfigSnapshot LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, registeredSubclassesToSerializerConfigSnapshots LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, nonRegisteredSubclassesToSerializerConfigSnapshots HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>) in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Parameter Type serializerConfigSnapshot : TypeSerializerConfigSnapshot<T> to serializerConfigSnapshot : TypeSerializerSnapshot<T> in method package TypeSerializerSnapshotSerializationProxy(serializerConfigSnapshot TypeSerializerSnapshot<T>, serializer TypeSerializer<T>) in class org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil.TypeSerializerSnapshotSerializationProxy |
From |
To |
|
Change Parameter Type fieldToSerializerConfigSnapshot : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to fieldToSerializerConfigSnapshot : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public PojoSerializerConfigSnapshot(pojoType Class<T>, fieldToSerializerConfigSnapshot LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, registeredSubclassesToSerializerConfigSnapshots LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, nonRegisteredSubclassesToSerializerConfigSnapshots HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>) in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Parameter Type serializerConfigSnapshots : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshots : Map<String,TypeSerializerSnapshot<?>> in method public StateMetaInfoSnapshot(name String, backendStateType BackendStateType, options Map<String,String>, serializerConfigSnapshots Map<String,TypeSerializerSnapshot<?>>, serializers Map<String,TypeSerializer<?>>) in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot |
From |
To |
|
Change Parameter Type keySerializerConfigSnapshot : TypeSerializerConfigSnapshot to keySerializerConfigSnapshot : TypeSerializerSnapshot<K> in method public InternalTimersSnapshot(keySerializer TypeSerializer<K>, keySerializerConfigSnapshot TypeSerializerSnapshot<K>, namespaceSerializer TypeSerializer<N>, namespaceSerializerConfigSnapshot TypeSerializerSnapshot<N>, eventTimeTimers Set<TimerHeapInternalTimer<K,N>>, processingTimeTimers Set<TimerHeapInternalTimer<K,N>>) in class org.apache.flink.streaming.api.operators.InternalTimersSnapshot |
From |
To |
|
Change Parameter Type registeredSubclassesToSerializerConfigSnapshots : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to registeredSubclassesToSerializerConfigSnapshots : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public PojoSerializerConfigSnapshot(pojoType Class<T>, fieldToSerializerConfigSnapshot LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, registeredSubclassesToSerializerConfigSnapshots LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, nonRegisteredSubclassesToSerializerConfigSnapshots HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>) in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Parameter Type nonRegisteredSubclassesToSerializerConfigSnapshots : HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to nonRegisteredSubclassesToSerializerConfigSnapshots : HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public PojoSerializerConfigSnapshot(pojoType Class<T>, fieldToSerializerConfigSnapshot LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, registeredSubclassesToSerializerConfigSnapshots LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, nonRegisteredSubclassesToSerializerConfigSnapshots HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>, ignoreTypeSerializerSerialization boolean) in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Return Type List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public readSerializersAndConfigsWithResilience(in DataInputView, userCodeClassLoader ClassLoader) : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtil |
From |
To |
|
Change Return Type List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public getNestedSerializersAndConfigs() : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerConfigSnapshot |
From |
To |
|
Change Return Type TypeSerializerConfigSnapshot<T> to TypeSerializerSnapshot<T> in method public snapshotConfiguration() : TypeSerializerSnapshot<T> in class org.apache.flink.formats.avro.typeutils.BackwardsCompatibleAvroSerializer |
From |
To |
|
Change Return Type HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public getNonRegisteredSubclassesToSerializerConfigSnapshots() : HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T> to TypeSerializerSchemaCompatibility<T,NS> in method public incompatible() : TypeSerializerSchemaCompatibility<T,NS> in class org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility |
From |
To |
|
Change Return Type TypeSerializerConfigSnapshot to TypeSerializerSnapshot<?> in method public getTypeSerializerConfigSnapshot(key CommonSerializerKeys) : TypeSerializerSnapshot<?> in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T> to TypeSerializerSchemaCompatibility<T,NS> in method public compatibleAfterMigration() : TypeSerializerSchemaCompatibility<T,NS> in class org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility |
From |
To |
|
Change Return Type TypeSerializerConfigSnapshot to TypeSerializerSnapshot<K> in method public getKeySerializerConfigSnapshot() : TypeSerializerSnapshot<K> in class org.apache.flink.runtime.state.KeyedBackendSerializationProxy |
From |
To |
|
Change Return Type LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public getFieldToSerializerConfigSnapshot() : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Return Type Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public getSingleNestedSerializerAndConfig() : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerConfigSnapshot |
From |
To |
|
Change Return Type LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public getRegisteredSubclassesToSerializerConfigSnapshots() : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Return Type Map<String,TypeSerializerConfigSnapshot<?>> to Map<String,TypeSerializerSnapshot<?>> in method public getSerializerConfigSnapshotsImmutable() : Map<String,TypeSerializerSnapshot<?>> in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T> to TypeSerializerSchemaCompatibility<T,NS> in method public compatibleAsIs() : TypeSerializerSchemaCompatibility<T,NS> in class org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility |
From |
To |
|
Change Return Type TypeSerializerConfigSnapshot<T> to TypeSerializerSnapshot<T> in method public abstract snapshotConfiguration() : TypeSerializerSnapshot<T> in class org.apache.flink.api.common.typeutils.TypeSerializer |
From |
To |
|
Change Return Type TypeSerializerConfigSnapshot to TypeSerializerSnapshot<N> in method public getNamespaceSerializerConfigSnapshot() : TypeSerializerSnapshot<N> in class org.apache.flink.streaming.api.operators.InternalTimersSnapshot |
From |
To |
|
Change Return Type TypeSerializerConfigSnapshot to TypeSerializerSnapshot<K> in method public getKeySerializerConfigSnapshot() : TypeSerializerSnapshot<K> in class org.apache.flink.streaming.api.operators.InternalTimersSnapshot |
From |
To |
|
Change Return Type TypeSerializerConfigSnapshot to TypeSerializerSnapshot<?> in method public getTypeSerializerConfigSnapshot(key String) : TypeSerializerSnapshot<?> in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot |
From |
To |
|
Change Variable Type fieldToConfigSnapshotEntry : Map.Entry<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to fieldToConfigSnapshotEntry : Map.Entry<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<T> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type entry : Map.Entry<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to entry : Map.Entry<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method private verifyPojoSerializerConfigSnapshotWithSerializerSerializationFailure(original PojoSerializer.PojoSerializerConfigSnapshot<?>, deserializedConfig PojoSerializer.PojoSerializerConfigSnapshot<?>) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type previousKvSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousKvSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<Map<K,V>> in class org.apache.flink.api.common.typeutils.base.MapSerializer |
From |
To |
|
Change Variable Type previousSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<TaggedUnion<T1,T2>> in class org.apache.flink.streaming.api.datastream.CoGroupedStreams.UnionSerializer |
From |
To |
|
Change Variable Type serializerConfigSnapshotMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshotMap : Map<String,TypeSerializerSnapshot<?>> in method public readStateMetaInfoSnapshot(in DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.LegacyStateMetaInfoReaders.KeyedBackendStateMetaInfoReaderV1V2 |
From |
To |
|
Change Variable Type nonRegisteredSubclassesToSerializerConfigSnapshots : HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to nonRegisteredSubclassesToSerializerConfigSnapshots : HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method private buildConfigSnapshot(pojoType Class<T>, registeredSubclassesToTags LinkedHashMap<Class<?>,Integer>, registeredSubclassSerializers TypeSerializer<?>[], fields Field[], fieldSerializers TypeSerializer<?>[], nonRegisteredSubclassSerializerCache HashMap<Class<?>,TypeSerializer<?>>) : PojoSerializerConfigSnapshot<T> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type snapshot : TypeSerializerConfigSnapshot to snapshot : TypeSerializerSnapshot in method private checkCompatibility(enumSourceA String, enumSourceB String) : CompatibilityResult in class org.apache.flink.api.common.typeutils.base.EnumSerializerUpgradeTest |
From |
To |
|
Change Variable Type previousTypeSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to previousTypeSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<StreamElement> in class org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer |
From |
To |
|
Change Variable Type restoredConfig : TypeSerializerConfigSnapshot to restoredConfig : TypeSerializerSnapshot<PublicEnum> in method public testConfigurationSnapshotSerialization() : void in class org.apache.flink.api.common.typeutils.base.EnumSerializerTest |
From |
To |
|
Change Variable Type entry : Map.Entry<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to entry : Map.Entry<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method private verifyPojoSerializerConfigSnapshotWithSerializerSerializationFailure(original PojoSerializer.PojoSerializerConfigSnapshot<?>, deserializedConfig PojoSerializer.PojoSerializerConfigSnapshot<?>) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type previousElemSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to previousElemSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<ArrayList<T>> in class org.apache.flink.runtime.state.ArrayListSerializer |
From |
To |
|
Change Variable Type pojoSerializerConfigSnapshot : TypeSerializerConfigSnapshot to pojoSerializerConfigSnapshot : TypeSerializerSnapshot in method public testReconfigureDifferentSubclassRegistrationOrder() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type previousCachedEntry : Map.Entry<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousCachedEntry : Map.Entry<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<T> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type originalFieldSerializersAndConfs : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to originalFieldSerializersAndConfs : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method private verifyPojoSerializerConfigSnapshotWithSerializerSerializationFailure(original PojoSerializer.PojoSerializerConfigSnapshot<?>, deserializedConfig PojoSerializer.PojoSerializerConfigSnapshot<?>) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type serializerConfigTuple : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to serializerConfigTuple : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public readStateMetaInfoSnapshot(inputView DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters.V5ReaderImpl |
From |
To |
|
Change Variable Type registeredSubclassesToSerializerConfigSnapshots : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to registeredSubclassesToSerializerConfigSnapshots : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method private buildConfigSnapshot(pojoType Class<T>, registeredSubclassesToTags LinkedHashMap<Class<?>,Integer>, registeredSubclassSerializers TypeSerializer<?>[], fields Field[], fieldSerializers TypeSerializer<?>[], nonRegisteredSubclassSerializerCache HashMap<Class<?>,TypeSerializer<?>>) : PojoSerializerConfigSnapshot<T> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type serializerConfigSnapshotsMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshotsMap : Map<String,TypeSerializerSnapshot<?>> in method private computeSnapshot() : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.RegisteredOperatorStateBackendMetaInfo |
From |
To |
|
Change Variable Type serializersAndConfigSnapshots : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializersAndConfigSnapshots : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public readSerializersAndConfigsWithResilience(in DataInputView, userCodeClassLoader ClassLoader) : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtil |
From |
To |
|
Change Variable Type restoredConfigs : TypeSerializerConfigSnapshot<?> to restoredConfigs : TypeSerializerSnapshot<?> in method public testSerializeConfigurationSnapshots() : void in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest |
From |
To |
|
Change Variable Type keySerializerAndSnapshot : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to keySerializerAndSnapshot : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<TimerHeapInternalTimer<K,N>> in class org.apache.flink.streaming.api.operators.TimerSerializer |
From |
To |
|
Change Variable Type previousSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<TimerHeapInternalTimer<K,N>> in class org.apache.flink.streaming.api.operators.TimerSerializer |
From |
To |
|
Change Variable Type serializerSnapshotMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerSnapshotMap : Map<String,TypeSerializerSnapshot<?>> in method private computeSnapshot() : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.RegisteredPriorityQueueStateBackendMetaInfo |
From |
To |
|
Change Variable Type serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public testSerializerAndConfigPairsSerializationWithSerializerDeserializationFailures() : void in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest |
From |
To |
|
Change Variable Type serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public readStateMetaInfoSnapshot(in DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.LegacyStateMetaInfoReaders.KeyedBackendStateMetaInfoReaderV3V4 |
From |
To |
|
Change Variable Type serializerConfigsMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigsMap : Map<String,TypeSerializerSnapshot<?>> in method public readStateMetaInfoSnapshot(in DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV2V3 |
From |
To |
|
Change Variable Type serializerConfigSnapshotsMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshotsMap : Map<String,TypeSerializerSnapshot<?>> in method public writeStateMetaInfoSnapshot(snapshot StateMetaInfoSnapshot, outputView DataOutputView) : void in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters.CurrentWriterImpl |
From |
To |
|
Change Variable Type serializerConfigSnapshotsMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshotsMap : Map<String,TypeSerializerSnapshot<?>> in method private computeSnapshot() : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.RegisteredBroadcastStateBackendMetaInfo |
From |
To |
|
Change Variable Type entry : Map.Entry<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to entry : Map.Entry<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public write(out DataOutputView) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Variable Type restored : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to restored : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public testSerializerAndConfigPairsSerializationWithSerializerDeserializationFailures() : void in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtilTest |
From |
To |
|
Change Variable Type namespaceSerializerAndSnapshot : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to namespaceSerializerAndSnapshot : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<TimerHeapInternalTimer<K,N>> in class org.apache.flink.streaming.api.operators.TimerSerializer |
From |
To |
|
Change Variable Type serAndConfSnapshot : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to serAndConfSnapshot : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public writeSerializersAndConfigsWithResilience(out DataOutputView, serializersAndConfigs List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>>) : void in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtil |
From |
To |
|
Change Variable Type serializersWithConfig : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializersWithConfig : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public readStateMetaInfoSnapshot(inputView DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters.V5ReaderImpl |
From |
To |
|
Change Variable Type pojoSerializerConfigSnapshot : TypeSerializerConfigSnapshot to pojoSerializerConfigSnapshot : TypeSerializerSnapshot in method public testReconfigureWithDifferentPojoType() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type keySerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to keySerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public read(in DataInputView) : void in class org.apache.flink.runtime.state.KeyedBackendSerializationProxy |
From |
To |
|
Change Variable Type previousRegisteredSerializerConfig : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to previousRegisteredSerializerConfig : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<T> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type previousLeftRightSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousLeftRightSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<Either<L,R>> in class org.apache.flink.api.java.typeutils.runtime.EitherSerializer |
From |
To |
|
Change Variable Type kryoSerializerConfigSnapshot : TypeSerializerConfigSnapshot to kryoSerializerConfigSnapshot : TypeSerializerSnapshot in method public testMigrationStrategyForRemovedAvroDependency() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerCompatibilityTest |
From |
To |
|
Change Variable Type kryoSerializerConfigSnapshot : TypeSerializerConfigSnapshot to kryoSerializerConfigSnapshot : TypeSerializerSnapshot in method public testMigrationStrategyWithDifferentKryoType() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerCompatibilityTest |
From |
To |
|
Change Variable Type stateSerializerAndConfigList : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to stateSerializerAndConfigList : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public readStateMetaInfoSnapshot(in DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV2V3 |
From |
To |
|
Change Variable Type fieldSerializerConfigSnapshot : TypeSerializerConfigSnapshot to fieldSerializerConfigSnapshot : TypeSerializerSnapshot in method public read(in DataInputView) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Variable Type originalRegistrations : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to originalRegistrations : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method private verifyPojoSerializerConfigSnapshotWithSerializerSerializationFailure(original PojoSerializer.PojoSerializerConfigSnapshot<?>, deserializedConfig PojoSerializer.PojoSerializerConfigSnapshot<?>) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type serializerConfigSnapshotMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshotMap : Map<String,TypeSerializerSnapshot<?>> in method public readStateMetaInfoSnapshot(in DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.LegacyStateMetaInfoReaders.KeyedBackendStateMetaInfoReaderV3V4 |
From |
To |
|
Change Variable Type serializerConfigsMap : HashMap<String,TypeSerializerConfigSnapshot<?>> to serializerConfigsMap : HashMap<String,TypeSerializerSnapshot<?>> in method public readStateMetaInfoSnapshot(inputView DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters.CurrentReaderImpl |
From |
To |
|
Change Variable Type f : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to f : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<Row> in class org.apache.flink.api.java.typeutils.runtime.RowSerializer |
From |
To |
|
Change Variable Type deserialized : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to deserialized : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public testCompatibilityWithPojoSerializer() : void in class org.apache.flink.formats.avro.typeutils.BackwardsCompatibleAvroSerializerTest |
From |
To |
|
Change Variable Type nestedSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to nestedSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<Lockable<E>> in class org.apache.flink.cep.nfa.sharedbuffer.Lockable.LockableTypeSerializer |
From |
To |
|
Change Variable Type serializerConfigSnapshots : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializerConfigSnapshots : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<SharedBuffer<V>> in class org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializer |
From |
To |
|
Change Variable Type serializerConfigsMap : HashMap<String,TypeSerializerConfigSnapshot<?>> to serializerConfigsMap : HashMap<String,TypeSerializerSnapshot<?>> in method public readStateMetaInfoSnapshot(inputView DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters.V5ReaderImpl |
From |
To |
|
Change Variable Type kryoSerializerConfigSnapshot : TypeSerializerConfigSnapshot to kryoSerializerConfigSnapshot : TypeSerializerSnapshot in method public testMigrationStrategyForDifferentRegistrationOrder() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerCompatibilityTest |
From |
To |
|
Change Variable Type mockOriginalFieldToSerializerConfigSnapshot : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to mockOriginalFieldToSerializerConfigSnapshot : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public testReconfigureWithDifferentFieldOrder() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type fieldToSerializerConfigSnapshots : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to fieldToSerializerConfigSnapshots : LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method private buildConfigSnapshot(pojoType Class<T>, registeredSubclassesToTags LinkedHashMap<Class<?>,Integer>, registeredSubclassSerializers TypeSerializer<?>[], fields Field[], fieldSerializers TypeSerializer<?>[], nonRegisteredSubclassSerializerCache HashMap<Class<?>,TypeSerializer<?>>) : PojoSerializerConfigSnapshot<T> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type previousRegistrations : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousRegistrations : LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<T> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type restoredConfig : TypeSerializerConfigSnapshot to restoredConfig : TypeSerializerSnapshot<T> in method public testSnapshotConfigurationAndReconfigure() : void in class org.apache.flink.api.common.typeutils.SerializerTestBase |
From |
To |
|
Change Variable Type restoredSnapshot : TypeSerializerConfigSnapshot to restoredSnapshot : TypeSerializerSnapshot in method private checkCompatibility(enumSourceA String, enumSourceB String) : CompatibilityResult in class org.apache.flink.api.common.typeutils.base.EnumSerializerUpgradeTest |
From |
To |
|
Change Variable Type previousSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<State<TXN,CONTEXT>> in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.StateSerializer |
From |
To |
|
Change Variable Type pojoSerializerConfigSnapshot : TypeSerializerConfigSnapshot to pojoSerializerConfigSnapshot : TypeSerializerSnapshot in method public testReconfigureRepopulateNonregisteredSubclassSerializerCache() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type registeredSubclassSerializerConfigSnapshot : TypeSerializerConfigSnapshot to registeredSubclassSerializerConfigSnapshot : TypeSerializerSnapshot in method public read(in DataInputView) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Variable Type serializerConfigSnapshotClass : Class<? extends TypeSerializerConfigSnapshot> to serializerConfigSnapshotClass : Class<? extends TypeSerializerSnapshot> in method public read(in DataInputView) : void in class org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil.TypeSerializerSnapshotSerializationProxy |
From |
To |
|
Change Variable Type configSnapshot : TypeSerializerConfigSnapshot<?> to configSnapshot : TypeSerializerSnapshot<?> in method public readSerializersAndConfigsWithResilience(in DataInputView, userCodeClassLoader ClassLoader) : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in class org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtil |
From |
To |
|
Change Variable Type serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<MigratedNFA<T>> in class org.apache.flink.cep.nfa.NFA.NFASerializer |
From |
To |
|
Change Variable Type that : BackwardsCompatibleConfigSnapshot<?> to that : BackwardsCompatibleSerializerSnapshot<?> in method public equals(o Object) : boolean in class org.apache.flink.api.common.typeutils.BackwardsCompatibleSerializerSnapshot |
From |
To |
|
Change Variable Type entry : Map.Entry<String,TypeSerializerConfigSnapshot<?>> to entry : Map.Entry<String,TypeSerializerSnapshot<?>> in method public writeStateMetaInfoSnapshot(snapshot StateMetaInfoSnapshot, outputView DataOutputView) : void in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters.CurrentWriterImpl |
From |
To |
|
Change Variable Type nextSnapshot : TypeSerializerConfigSnapshot to nextSnapshot : TypeSerializerSnapshot<SimpleUser> in method public testCompatibilityWithPojoSerializer() : void in class org.apache.flink.formats.avro.typeutils.BackwardsCompatibleAvroSerializerTest |
From |
To |
|
Change Variable Type previousFieldSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to previousFieldSerializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot<?>) : CompatibilityResult<Row> in class org.apache.flink.api.java.typeutils.runtime.RowSerializer |
From |
To |
|
Change Variable Type configSnapshot : TypeSerializerConfigSnapshot<?> to configSnapshot : TypeSerializerSnapshot<?> in method public restoreTypeSerializer(key String) : TypeSerializer<?> in class org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot |
From |
To |
|
Change Variable Type serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to serializersAndConfigs : List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method protected restoreKeyAndNamespaceSerializers(restoredTimersSnapshot InternalTimersSnapshot<K,N>, in DataInputView) : void in class org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReaderV1 |
From |
To |
|
Change Variable Type cachedSubclassSerializerConfigSnapshot : TypeSerializerConfigSnapshot to cachedSubclassSerializerConfigSnapshot : TypeSerializerSnapshot in method public read(in DataInputView) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Variable Type previousElemSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to previousElemSerializerAndConfig : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public ensureCompatibility(configSnapshot TypeSerializerConfigSnapshot) : CompatibilityResult<List<T>> in class org.apache.flink.api.common.typeutils.base.ListSerializer |
From |
To |
|
Change Variable Type configSnapshot : TypeSerializerConfigSnapshot to configSnapshot : TypeSerializerSnapshot<SimpleUser> in method public testCompatibilityWithPojoSerializer() : void in class org.apache.flink.formats.avro.typeutils.BackwardsCompatibleAvroSerializerTest |
From |
To |
|
Change Variable Type pojoSerializerConfigSnapshot : TypeSerializerConfigSnapshot to pojoSerializerConfigSnapshot : TypeSerializerSnapshot in method public testReconfigureWithPreviouslyNonregisteredSubclasses() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type entry : Map.Entry<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> to entry : Map.Entry<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> in method public write(out DataOutputView) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot |
From |
To |
|
Change Variable Type configSnapshot : TypeSerializerConfigSnapshot to configSnapshot : TypeSerializerSnapshot<T> in method public testConfigSnapshotInstantiation() : void in class org.apache.flink.api.common.typeutils.SerializerTestBase |
From |
To |
|
Change Variable Type serializerConfigSnapshotsMap : Map<String,TypeSerializerConfigSnapshot<?>> to serializerConfigSnapshotsMap : Map<String,TypeSerializerSnapshot<?>> in method private computeSnapshot() : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo |
From |
To |
|
Change Variable Type configSnapshot : TypeSerializerConfigSnapshot to configSnapshot : TypeSerializerSnapshot<T> in method public testSnapshotConfigurationAndReconfigure() : void in class org.apache.flink.api.common.typeutils.SerializerTestBase |
From |
To |
|
Change Variable Type serializerAndConf : Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> to serializerAndConf : Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> in method public readStateMetaInfoSnapshot(in DataInputView, userCodeClassLoader ClassLoader) : StateMetaInfoSnapshot in class org.apache.flink.runtime.state.metainfo.LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV2V3 |
From |
To |
|
Change Variable Type configSnapshot : TypeSerializerConfigSnapshot to configSnapshot : TypeSerializerSnapshot<?> in method public CompositeTypeSerializerConfigSnapshot(nestedSerializers TypeSerializer<?>...) in class org.apache.flink.api.common.typeutils.CompositeTypeSerializerConfigSnapshot |
From |
To |