040356391f621858199948b15160b1e382152cc1
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 15
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public registerSharedStates(sharedStateRegistry SharedStateRegistry) : void renamed to public registerSharedStatesAfterRestored(sharedStateRegistry SharedStateRegistry) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
| Change Return Type | 1 | ||
| Change Return Type AbstractCompletedCheckpointStore to CompletedCheckpointStore in method protected createCompletedCheckpoints(maxNumberOfCheckpointsToRetain int) : CompletedCheckpointStore in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest | From | To | |
| Move Attribute | 1 | ||
| Move Attribute protected sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.checkpoint.AbstractCompletedCheckpointStore to private sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type checkpoints : AbstractCompletedCheckpointStore to checkpoints : CompletedCheckpointStore in method public testRecover() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStoreITCase | From | To | |
| Change Variable Type store : AbstractCompletedCheckpointStore to store : CompletedCheckpointStore in method public testSuspendDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest | From | To | |
| Change Variable Type checkpointStore : AbstractCompletedCheckpointStore to checkpointStore : CompletedCheckpointStore in method public testLatestCheckpointRecovery() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStoreITCase | From | To | |
| Change Variable Type store : AbstractCompletedCheckpointStore to store : CompletedCheckpointStore in method public testShutdownDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest | From | To |