0162543ac13f048ef67a6586d8a6e8021ec9dcd4
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 27
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 4 | ||
| Rename Method public registerNewReference(registrationKey SharedStateRegistryKey, state StreamStateHandle) : Result renamed to public registerReference(registrationKey SharedStateRegistryKey, state StreamStateHandle) : Result in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Rename Method public releaseReference(registrationKey SharedStateRegistryKey) : Result renamed to public unregisterReference(registrationKey SharedStateRegistryKey) : Result in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Rename Method private createRandomOwnedHandleMap(rnd Random) : Map<StateHandleID,StreamStateHandle> renamed to public createRandomStateHandleMap(rnd Random) : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.runtime.checkpoint.savepoint.CheckpointTestUtils | From | To | |
| Rename Method public getCreatedSharedState() : Map<StateHandleID,StreamStateHandle> renamed to public getSharedState() : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle | From | To | |
| Merge Attribute | 1 | ||
| Merge Attribute [newSstFiles : Map<StateHandleID,StreamStateHandle>, oldSstFiles : Map<StateHandleID,StreamStateHandle>] to sstFiles : Map<StateHandleID,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Inline Method | 1 | ||
| Inline Method public getPrivateStateSize() : long inlined to public getStateSize() : long in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle | From | To | |
| Rename Variable | 5 | ||
| Rename Variable newSstFiles : Map<StateHandleID,StreamStateHandle> to sstFiles : Map<StateHandleID,StreamStateHandle> in method private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Rename Variable miscFileHandle : StreamStateHandle to privateStateHandle : StreamStateHandle in method public getStateSize() : long in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle | From | To | |
| Rename Variable oldSstFileHandle : StreamStateHandle to sharedStateHandle : StreamStateHandle in method public getStateSize() : long in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle | From | To | |
| Rename Variable oldSstFileName : Map.Entry<StateHandleID,StreamStateHandle> to sharedStateHandle : Map.Entry<StateHandleID,StreamStateHandle> in method public registerSharedStates(stateRegistry SharedStateRegistry) : void in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle | From | To | |
| Rename Variable newSstFileHandle : StreamStateHandle to sharedStateHandle : StreamStateHandle in method public getStateSize() : long in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle | From | To | |
| Change Return Type | 1 | ||
| Change Return Type List<Long> to List<Tuple2<Long,Integer>> in method public snapshotState(checkpointId long, timestamp long) : List<Tuple2<Long,Integer>> in class org.apache.flink.test.recovery.JobManagerHACheckpointRecoveryITCase.CheckpointedSequenceSource | From | To | |
| Merge Variable | 1 | ||
| Merge Variable [createdStates : Map<StateHandleID,StreamStateHandle>, referencedStates : Map<StateHandleID,StreamStateHandle>] to sharedStates : Map<StateHandleID,StreamStateHandle> in method private deserializeKeyedStateHandle(dis DataInputStream) : KeyedStateHandle in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute checkpointStateHandles : ArrayDeque<Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String>> to completedCheckpoints : ArrayDeque<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type checkpoint : Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String> to checkpoint : CompletedCheckpoint in method public shutdown(jobStatus JobStatus) : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore | From | To | |
| Inline Variable | 1 | ||
| Inline Variable fileHandle : StreamStateHandle in method package materializeSnapshot() : KeyedStateHandle from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type baseSstFiles : Map<StateHandleID,StreamStateHandle> to baseSstFiles : Set<StateHandleID> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Change Attribute Type checkpointStateHandles : ArrayDeque<Tuple2<RetrievableStateHandle<CompletedCheckpoint>,String>> to completedCheckpoints : ArrayDeque<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore | From | To | |
| Change Attribute Type materializedSstFiles : SortedMap<Long,Map<StateHandleID,StreamStateHandle>> to materializedSstFiles : SortedMap<Long,Set<StateHandleID>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter createdSharedState : Map<StateHandleID,StreamStateHandle> to sharedState : Map<StateHandleID,StreamStateHandle> in method public IncrementalKeyedStateHandle(operatorIdentifier String, keyGroupRange KeyGroupRange, checkpointId long, sharedState Map<StateHandleID,StreamStateHandle>, privateState Map<StateHandleID,StreamStateHandle>, metaStateHandle StreamStateHandle) in class org.apache.flink.runtime.state.IncrementalKeyedStateHandle | From | To |