|
Change Parameter Type metaInfo : RegisteredBackendStateMetaInfo<N,S> to metaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method private CopyOnWriteStateTable(keyContext InternalKeyContext<K>, metaInfo RegisteredKeyedBackendStateMetaInfo<N,S>, capacity int) in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable |
From |
To |
|
Change Parameter Type metaInfo : RegisteredBackendStateMetaInfo<N,S> to metaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method package CopyOnWriteStateTable(keyContext InternalKeyContext<K>, metaInfo RegisteredKeyedBackendStateMetaInfo<N,S>) in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable |
From |
To |
|
Change Parameter Type namedStateSerializationProxies : List<StateMetaInfo<?>> to stateMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public OperatorBackendSerializationProxy(stateMetaInfoSnapshots List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>>) in class org.apache.flink.runtime.state.OperatorBackendSerializationProxy |
From |
To |
|
Change Parameter Type metaInfo : RegisteredBackendStateMetaInfo<N,S> to metaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method public StateTable(keyContext InternalKeyContext<K>, metaInfo RegisteredKeyedBackendStateMetaInfo<N,S>) in class org.apache.flink.runtime.state.heap.StateTable |
From |
To |
|
Change Parameter Type metaInfo : RegisteredBackendStateMetaInfo<N,S> to metaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method public setMetaInfo(metaInfo RegisteredKeyedBackendStateMetaInfo<N,S>) : void in class org.apache.flink.runtime.state.heap.StateTable |
From |
To |
|
Change Parameter Type name : String to stateMetaInfo : RegisteredOperatorBackendStateMetaInfo<S> in method private PartitionableListState(stateMetaInfo RegisteredOperatorBackendStateMetaInfo<S>, internalList ArrayList<S>) in class org.apache.flink.runtime.state.DefaultOperatorStateBackend.PartitionableListState |
From |
To |
|
Change Parameter Type namedStateSerializationProxies : List<StateMetaInfo<?,?>> to stateMetaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method public KeyedBackendSerializationProxy(keySerializer TypeSerializer<?>, stateMetaInfoSnapshots List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>>) in class org.apache.flink.runtime.state.KeyedBackendSerializationProxy |
From |
To |
|
Change Parameter Type newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to newMetaInfo : RegisteredKeyedBackendStateMetaInfo<N,V> in method public newStateTable(newMetaInfo RegisteredKeyedBackendStateMetaInfo<N,V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type stateSerializerSerializationProxy : TypeSerializerSerializationProxy<S> to stateSerializer : TypeSerializer<S> in method package setStateSerializer(stateSerializer TypeSerializer<S>) : void in class org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo.Snapshot |
From |
To |
|
Change Parameter Type metaInfo : RegisteredBackendStateMetaInfo<N,S> to metaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method public NestedMapsStateTable(keyContext InternalKeyContext<K>, metaInfo RegisteredKeyedBackendStateMetaInfo<N,S>) in class org.apache.flink.runtime.state.heap.NestedMapsStateTable |
From |
To |
|
Change Parameter Type namespaceSerializerSerializationProxy : TypeSerializerSerializationProxy<N> to namespaceSerializer : TypeSerializer<N> in method package setNamespaceSerializer(namespaceSerializer TypeSerializer<N>) : void in class org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo.Snapshot |
From |
To |
|
Change Parameter Type metaInfo : RegisteredBackendStateMetaInfo<N,S> to metaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method public setMetaInfo(metaInfo RegisteredKeyedBackendStateMetaInfo<N,S>) : void in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTable |
From |
To |
|
Change Variable Type metaInfo : RegisteredBackendStateMetaInfo<Integer,ArrayList<Integer>> to metaInfo : RegisteredKeyedBackendStateMetaInfo<Integer,ArrayList<Integer>> in method public checkCompatibleSerializationFormats() : void in class org.apache.flink.runtime.state.heap.StateTableSnapshotCompatibilityTest |
From |
To |
|
Change Variable Type metaInfoList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to restoredMetaInfos : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private restorePartitionedState(state Collection<KeyedStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type registeredBackendStateMetaInfo : RegisteredBackendStateMetaInfo<N,S> to registeredKeyedBackendStateMetaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method public deserialize(stateName String, stateBackend HeapKeyedStateBackend<K>) : StateTable<K,N,S> in class org.apache.flink.migration.runtime.state.memory.AbstractMigrationRestoreStrategy |
From |
To |
|
Change Variable Type metaInfoProxyList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to metaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<KeyedStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type metaInfoList : List<OperatorBackendSerializationProxy.StateMetaInfo<?>> to metaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public performOperation() : OperatorStateHandle in class org.apache.flink.runtime.state.DefaultOperatorStateBackend.snapshot.ioCallable |
From |
To |
|
Change Variable Type that : StateMetaInfo<?,?> to that : Snapshot<?,?> in method public equals(o Object) : boolean in class org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo.Snapshot |
From |
To |
|
Change Variable Type stateMetaInfoProxy : KeyedBackendSerializationProxy.StateMetaInfo<?,?> to stateMetaInfoSnapshot : RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?> in method private restoreInstance(restoreStateHandle RocksDBIncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type metaInfo : RegisteredBackendStateMetaInfo<Integer,ArrayList<Integer>> to metaInfo : RegisteredKeyedBackendStateMetaInfo<Integer,ArrayList<Integer>> in method public testCopyOnWriteContracts() : void in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest |
From |
To |
|
Change Variable Type stateMetaInfoList : List<OperatorBackendSerializationProxy.StateMetaInfo<?>> to stateMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public testOperatorBackendSerializationProxyRoundtrip() : void in class org.apache.flink.runtime.state.SerializationProxiesTest |
From |
To |
|
Change Variable Type cleanedTaggedClasses : List<Class<?>> to registeredSubclasses : LinkedHashSet<Class<?>> in method private createRegisteredSubclassTags(registeredSubclasses LinkedHashSet<Class<?>>) : LinkedHashMap<Class<?>,Integer> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type column : Map.Entry<String,Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>>> to column : Map.Entry<String,Tuple2<ColumnFamilyHandle,RegisteredKeyedBackendStateMetaInfo<?,?>>> in method private writeKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation |
From |
To |
|
Change Variable Type metaInfo : RegisteredBackendStateMetaInfo<Integer,ArrayList<Integer>> to metaInfo : RegisteredKeyedBackendStateMetaInfo<Integer,ArrayList<Integer>> in method public testPutGetRemoveContainsTransform() : void in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest |
From |
To |
|
Change Variable Type metaInfo : RegisteredBackendStateMetaInfo<Integer,Integer> to metaInfo : RegisteredKeyedBackendStateMetaInfo<Integer,Integer> in method public testSerializerDuplicationInSnapshot() : void in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest |
From |
To |
|
Change Variable Type registeredBackendStateMetaInfo : RegisteredBackendStateMetaInfo<VoidNamespace,Integer> to registeredKeyedBackendStateMetaInfo : RegisteredKeyedBackendStateMetaInfo<VoidNamespace,Integer> in method public testIntegrationWithKvStateServer() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Change Variable Type stateMetaInfoProxies : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to stateMetaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private restoreInstance(restoreStateHandle RocksDBIncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type column : Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>> to column : Tuple2<ColumnFamilyHandle,RegisteredKeyedBackendStateMetaInfo<?,?>> in method public dispose() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type tuple : Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<N,S>> to tuple : Tuple2<ColumnFamilyHandle,RegisteredKeyedBackendStateMetaInfo<N,S>> in method protected getColumnFamily(descriptor StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type stateMetaInfoList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to stateMetaInfoList : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method public testKeyedBackendSerializationProxyRoundtrip() : void in class org.apache.flink.runtime.state.SerializationProxiesTest |
From |
To |
|
Change Variable Type stateMetaInfoEntry : Map.Entry<String,Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>>> to stateMetaInfoEntry : Map.Entry<String,Tuple2<ColumnFamilyHandle,RegisteredKeyedBackendStateMetaInfo<?,?>>> in method package takeSnapshot() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation |
From |
To |
|
Change Variable Type stateMetaInfo : OperatorBackendSerializationProxy.StateMetaInfo<?> to restoredMetaInfo : RegisteredOperatorBackendStateMetaInfo.Snapshot<?> in method public restore(restoreSnapshots Collection<OperatorStateHandle>) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type metaInfo : RegisteredBackendStateMetaInfo<Integer,ArrayList<Integer>> to metaInfo : RegisteredKeyedBackendStateMetaInfo<Integer,ArrayList<Integer>> in method public testIncrementalRehash() : void in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest |
From |
To |
|
Change Variable Type metaInfoSerializationProxy : KeyedBackendSerializationProxy.StateMetaInfo<?,?> to restoredMetaInfo : RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?> in method private restorePartitionedState(state Collection<KeyedStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type metaInfoList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to metaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private writeKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation |
From |
To |
|
Change Variable Type registeredBackendStateMetaInfo : RegisteredBackendStateMetaInfo<?,?> to registeredKeyedBackendStateMetaInfo : RegisteredKeyedBackendStateMetaInfo<?,?> in method private restorePartitionedState(state Collection<KeyedStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type metaInfo : RegisteredBackendStateMetaInfo<Integer,ArrayList<Integer>> to metaInfo : RegisteredKeyedBackendStateMetaInfo<Integer,ArrayList<Integer>> in method public testRandomModificationsAndCopyOnWriteIsolation() : void in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest |
From |
To |
|
Change Variable Type stateInfo : Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>> to stateInfo : Tuple2<ColumnFamilyHandle,RegisteredKeyedBackendStateMetaInfo<?,?>> in method protected getColumnFamily(descriptor StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type metaInfoList : List<OperatorBackendSerializationProxy.StateMetaInfo<?>> to restoredMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public restore(restoreSnapshots Collection<OperatorStateHandle>) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type newMetaInfo : RegisteredBackendStateMetaInfo<N,V> to newMetaInfo : RegisteredKeyedBackendStateMetaInfo<N,V> in method private tryRegisterStateTable(stateName String, stateType StateDescriptor.Type, namespaceSerializer TypeSerializer<N>, valueSerializer TypeSerializer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type newMetaInfo : RegisteredBackendStateMetaInfo<N,S> to newMetaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method protected getColumnFamily(descriptor StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type metaInfoProxyList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to restoredMetaInfos : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Change Variable Type registeredStateMetaInfoEntry : Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>> to registeredStateMetaInfoEntry : Tuple2<ColumnFamilyHandle,RegisteredKeyedBackendStateMetaInfo<?,?>> in method private restoreInstance(restoreStateHandle RocksDBIncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Change Variable Type that : RegisteredBackendStateMetaInfo<?,?> to that : RegisteredKeyedBackendStateMetaInfo<?,?> in method public equals(o Object) : boolean in class org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo |
From |
To |
|
Change Variable Type metaInfoProxy : KeyedBackendSerializationProxy.StateMetaInfo<?,?> to restoredMetaInfo : RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Rename Variable metaInfoList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to restoredMetaInfos : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private restorePartitionedState(state Collection<KeyedStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable stateMetaInfo : OperatorBackendSerializationProxy.StateMetaInfo<?> to restoredMetaInfo : RegisteredOperatorBackendStateMetaInfo.Snapshot<?> in method public restore(restoreSnapshots Collection<OperatorStateHandle>) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Rename Variable metaInfoProxyList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to metaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<KeyedStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable registeredBackendStateMetaInfo : RegisteredBackendStateMetaInfo<N,S> to registeredKeyedBackendStateMetaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in method public deserialize(stateName String, stateBackend HeapKeyedStateBackend<K>) : StateTable<K,N,S> in class org.apache.flink.migration.runtime.state.memory.AbstractMigrationRestoreStrategy |
From |
To |
|
Rename Variable metaInfoSerializationProxy : KeyedBackendSerializationProxy.StateMetaInfo<?,?> to restoredMetaInfo : RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?> in method private restorePartitionedState(state Collection<KeyedStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable stateMetaInfoProxy : KeyedBackendSerializationProxy.StateMetaInfo<?,?> to stateMetaInfoSnapshot : RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?> in method private restoreInstance(restoreStateHandle RocksDBIncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Rename Variable stateMetaInfoList : List<OperatorBackendSerializationProxy.StateMetaInfo<?>> to stateMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public testOperatorBackendSerializationProxyRoundtrip() : void in class org.apache.flink.runtime.state.SerializationProxiesTest |
From |
To |
|
Rename Variable metaInfoList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to metaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private writeKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation |
From |
To |
|
Rename Variable registeredBackendStateMetaInfo : RegisteredBackendStateMetaInfo<?,?> to registeredKeyedBackendStateMetaInfo : RegisteredKeyedBackendStateMetaInfo<?,?> in method private restorePartitionedState(state Collection<KeyedStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable registeredBackendStateMetaInfo : RegisteredBackendStateMetaInfo<VoidNamespace,Integer> to registeredKeyedBackendStateMetaInfo : RegisteredKeyedBackendStateMetaInfo<VoidNamespace,Integer> in method public testIntegrationWithKvStateServer() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Rename Variable stateMetaInfoProxies : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to stateMetaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private restoreInstance(restoreStateHandle RocksDBIncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation |
From |
To |
|
Rename Variable metaInfoList : List<OperatorBackendSerializationProxy.StateMetaInfo<?>> to restoredMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in method public restore(restoreSnapshots Collection<OperatorStateHandle>) : void in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Rename Variable metaInfoProxyList : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to restoredMetaInfos : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Rename Variable metaInfoProxy : KeyedBackendSerializationProxy.StateMetaInfo<?,?> to restoredMetaInfo : RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?> in method private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation |
From |
To |
|
Change Attribute Type stateSerializerSerializationProxy : TypeSerializerSerializationProxy<S> to stateSerializer : TypeSerializer<S> in class org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo.Snapshot |
From |
To |
|
Change Attribute Type metaInfo : RegisteredBackendStateMetaInfo<N,S> to metaInfo : RegisteredKeyedBackendStateMetaInfo<N,S> in class org.apache.flink.runtime.state.heap.StateTable |
From |
To |
|
Change Attribute Type subclassSerializerCache : Map<Class<?>,TypeSerializer<?>> to subclassSerializerCache : HashMap<Class<?>,TypeSerializer<?>> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Attribute Type kvStateInformation : Map<String,Tuple2<ColumnFamilyHandle,RegisteredBackendStateMetaInfo<?,?>>> to kvStateInformation : Map<String,Tuple2<ColumnFamilyHandle,RegisteredKeyedBackendStateMetaInfo<?,?>>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Attribute Type registeredClasses : Map<Class<?>,Integer> to registeredClasses : LinkedHashMap<Class<?>,Integer> in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Attribute Type name : String to stateMetaInfo : RegisteredOperatorBackendStateMetaInfo<S> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend.PartitionableListState |
From |
To |
|
Change Attribute Type namespaceSerializerSerializationProxy : TypeSerializerSerializationProxy<N> to namespaceSerializer : TypeSerializer<N> in class org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo.Snapshot |
From |
To |
|
Change Attribute Type stateMetaInfos : List<KeyedBackendSerializationProxy.StateMetaInfo<?,?>> to stateMetaInfoSnapshots : List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation |
From |
To |
|
Change Attribute Type namedStateSerializationProxies : List<StateMetaInfo<?>> to stateMetaInfoSnapshots : List<RegisteredOperatorBackendStateMetaInfo.Snapshot<?>> in class org.apache.flink.runtime.state.OperatorBackendSerializationProxy |
From |
To |