6e7a91741708a2b167a2bbca5dda5b2059df5e18
Files Diff
- Added: 5
- Removed: 0
- Renamed: 0
- Modified: 69
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public removeSavepoint(path String) : void renamed to public removeSavepointFile(path String) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type path : Path to savepointFileOrDirectory : String in method public loadSavepoint(savepointFileOrDirectory String, userClassLoader ClassLoader) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
| Inline Method | 1 | ||
| Inline Method private createFsInputStream(path Path) : FSDataInputStream inlined to public loadSavepoint(savepointFileOrDirectory String, userClassLoader ClassLoader) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
| Rename Variable | 2 | ||
| Rename Variable result : CheckpointTriggerResult to triggerResult : CheckpointTriggerResult in method public triggerSavepoint(timestamp long, targetDirectory String) : Future<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Variable savepointDir : File to savepointRootDir : File in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase | From | To | |
| Parameterize Variable | 1 | ||
| Parameterize Variable basePath : Path to checkpointDirectory : Path in method protected createBasePath(fs FileSystem, checkpointDirectory Path, jobID JobID) : Path in class org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory | From | To | |
| Extract Variable | 2 | ||
| Extract Variable list : File[] in method public testMultipleSavepointVersions() : void from class org.apache.flink.runtime.checkpoint.savepoint.SavepointStoreTest | From | To | |
| Extract Variable list : File[] in method public testStoreLoadDispose() : void from class org.apache.flink.runtime.checkpoint.savepoint.SavepointStoreTest | From | To | |
| Extract Method | 1 | ||
| Extract Method protected createBasePath(fs FileSystem, checkpointDirectory Path, jobID JobID) : Path extracted from public FsCheckpointStreamFactory(checkpointDataUri Path, jobId JobID, fileStateSizeThreshold int) in class org.apache.flink.runtime.state.filesystem.FsCheckpointStreamFactory | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter path : String to savepointFileOrDirectory : String in method public loadSavepoint(savepointFileOrDirectory String, userClassLoader ClassLoader) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
| Rename Parameter path : Path to savepointFileOrDirectory : String in method public loadSavepoint(savepointFileOrDirectory String, userClassLoader ClassLoader) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
| Rename Parameter targetDirectory : String to directory : String in method public storeSavepoint(directory String, savepoint T) : String in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To |