|
Rename Variable kvState : Map.Entry<String,StateSnapshot> to stateSnapshot : Map.Entry<StateUID,StateSnapshot> in method protected performOperation() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy.performSnapshot.ioCallable |
From |
To |
|
Rename Variable entry : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to metaInfoTuple : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory |
From |
To |
|
Rename Variable entry : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to metaInfoTuple : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in method private tryRegisterPriorityQueueMetaInfo(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Variable restoredMetaInfo : StateMetaInfoSnapshot to metaInfoSnapshot : StateMetaInfoSnapshot in method private createOrCheckStateForMetaInfo(restoredMetaInfo List<StateMetaInfoSnapshot>, kvStatesById Map<Integer,StateMetaInfoSnapshot>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable snapshotRestore : StateSnapshotRestore to stateMetaInfoSnapshot : StateMetaInfoSnapshot in method private readKeyGroupStateData(inputStream InputStream, kvStatesById Map<Integer,StateMetaInfoSnapshot>, keyGroupIndex int, numStates int, readVersion int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable snapshotRestore : StateSnapshotRestore to existingState : HeapPriorityQueueSnapshotRestoreWrapper in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable kgCompressionInView : DataInputViewStreamWrapper to inView : DataInputViewStreamWrapper in method private readKeyGroupStateData(inputStream InputStream, kvStatesById Map<Integer,StateMetaInfoSnapshot>, keyGroupIndex int, numStates int, readVersion int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Variable kVStateToId : Map<String,Integer> to stateNamesToId : Map<StateUID,Integer> in method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Rename Variable stateName : String to stateUid : StateUID in method private processSnapshotMetaInfoForAllStates(metaInfoSnapshots List<StateMetaInfoSnapshot>, cowStateStableSnapshots Map<StateUID,StateSnapshot>, stateNamesToId Map<StateUID,Integer>, registeredStates Map<String,? extends StateSnapshotRestore>, stateType StateMetaInfoSnapshot.BackendStateType) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Parameterize Variable kgCompressionInStream : InputStream to inputStream : InputStream in method private readKeyGroupStateData(inputStream InputStream, kvStatesById Map<Integer,StateMetaInfoSnapshot>, keyGroupIndex int, numStates int, readVersion int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Parameterize Variable kVStateToId : Map<String,Integer> to stateNamesToId : Map<StateUID,Integer> in method private processSnapshotMetaInfoForAllStates(metaInfoSnapshots List<StateMetaInfoSnapshot>, cowStateStableSnapshots Map<StateUID,StateSnapshot>, stateNamesToId Map<StateUID,Integer>, registeredStates Map<String,? extends StateSnapshotRestore>, stateType StateMetaInfoSnapshot.BackendStateType) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Change Variable Type state : StateSnapshotRestore to state : StateTable<?,?,?> in method public numKeyValueStateEntries(namespace Object) : int in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type kVStateToId : Map<String,Integer> to stateNamesToId : Map<StateUID,Integer> in method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Change Variable Type stateName : String to stateUid : StateUID in method private processSnapshotMetaInfoForAllStates(metaInfoSnapshots List<StateMetaInfoSnapshot>, cowStateStableSnapshots Map<StateUID,StateSnapshot>, stateNamesToId Map<StateUID,Integer>, registeredStates Map<String,? extends StateSnapshotRestore>, stateType StateMetaInfoSnapshot.BackendStateType) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Change Variable Type kVStateToId : Map<String,Integer> to stateNamesToId : Map<StateUID,Integer> in method private processSnapshotMetaInfoForAllStates(metaInfoSnapshots List<StateMetaInfoSnapshot>, cowStateStableSnapshots Map<StateUID,StateSnapshot>, stateNamesToId Map<StateUID,Integer>, registeredStates Map<String,? extends StateSnapshotRestore>, stateType StateMetaInfoSnapshot.BackendStateType) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Change Variable Type cowStateStableSnapshots : Map<String,StateSnapshot> to cowStateStableSnapshots : Map<StateUID,StateSnapshot> in method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Change Variable Type kvState : Map.Entry<String,StateSnapshot> to stateSnapshot : Map.Entry<StateUID,StateSnapshot> in method protected performOperation() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy.performSnapshot.ioCallable |
From |
To |
|
Change Variable Type kvStatesById : Map<Integer,String> to kvStatesById : Map<Integer,StateMetaInfoSnapshot> in method private restorePartitionedState(state Collection<KeyedStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type kvState : Map.Entry<String,StateSnapshotRestore> to kvState : Map.Entry<String,? extends StateSnapshotRestore> in method private processSnapshotMetaInfoForAllStates(metaInfoSnapshots List<StateMetaInfoSnapshot>, cowStateStableSnapshots Map<StateUID,StateSnapshot>, stateNamesToId Map<StateUID,Integer>, registeredStates Map<String,? extends StateSnapshotRestore>, stateType StateMetaInfoSnapshot.BackendStateType) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy |
From |
To |
|
Change Variable Type snapshotRestore : StateSnapshotRestore to stateMetaInfoSnapshot : StateMetaInfoSnapshot in method private readKeyGroupStateData(inputStream InputStream, kvStatesById Map<Integer,StateMetaInfoSnapshot>, keyGroupIndex int, numStates int, readVersion int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type snapshotRestore : StateSnapshotRestore to existingState : HeapPriorityQueueSnapshotRestoreWrapper in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Extract And Move Method public notSupported() : StateMigrationException extracted from private getListState(stateDescriptor ListStateDescriptor<S>, mode OperatorStateHandle.Mode) : ListState<S> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend & moved to class org.apache.flink.util.StateMigrationException |
From |
To |
|
Extract And Move Method public notSupported() : StateMigrationException extracted from public resolveKvStateCompatibility(restoredStateMetaInfoSnapshot StateMetaInfoSnapshot, newNamespaceSerializer TypeSerializer<N>, newStateDescriptor StateDescriptor<?,S>) : RegisteredKeyValueStateBackendMetaInfo<N,S> in class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo & moved to class org.apache.flink.util.StateMigrationException |
From |
To |
|
Extract And Move Method public notSupported() : StateMigrationException extracted from public getBroadcastState(stateDescriptor MapStateDescriptor<K,V>) : BroadcastState<K,V> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend & moved to class org.apache.flink.util.StateMigrationException |
From |
To |