5b7f21d891b410ca0046efdaf12caf5e73deadf4
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 18
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 1 | ||
Rename Method public getExternalPath() : String renamed to public getExternalPointer() : String in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
Change Parameter Type | 1 | ||
Change Parameter Type searchType : Class to searchType : Class<?> in method public containsThrowable(throwable Throwable, searchType Class<?>) : boolean in class org.apache.flink.util.ExceptionUtils | From | To | |
Rename Variable | 1 | ||
Rename Variable suppressedExceptions : Exception to exception : Exception in method public bestEffortDiscardAllStateObjects(handlesToDiscard Iterable<? extends StateObject>) : void in class org.apache.flink.runtime.state.StateUtil | From | To | |
Rename Attribute | 1 | ||
Rename Attribute externalPath : String to externalPointer : String in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
Extract Method | 2 | ||
Extract Method public storeSavepointToHandle(directory String, savepoint T) : FileStateHandle extracted from public storeSavepoint(directory String, savepoint T) : String in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
Extract Method public loadSavepointWithHandle(savepointFileOrDirectory String, classLoader ClassLoader) : Tuple2<Savepoint,StreamStateHandle> extracted from public loadSavepoint(savepointFileOrDirectory String, userClassLoader ClassLoader) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
Change Attribute Type | 1 | ||
Change Attribute Type discardCallback : CompletedCheckpointStats.DiscardCallback to discardCallback : DiscardCallback in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
Rename Parameter | 4 | ||
Rename Parameter externalPath : String to externalPointer : String in method public CompletedCheckpoint(job JobID, checkpointID long, timestamp long, completionTimestamp long, taskStates Map<JobVertexID,TaskState>, props CheckpointProperties, externalizedMetadata StreamStateHandle, externalPointer String) in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
Rename Parameter userClassLoader : ClassLoader to classLoader : ClassLoader in method public loadSavepoint(savepointFileOrDirectory String, classLoader ClassLoader) : Savepoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To | |
Rename Parameter userClassLoader : ClassLoader to classLoader : ClassLoader in method public loadAndValidateSavepoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader | From | To | |
Rename Parameter userClassLoader : ClassLoader to classLoader : ClassLoader in method public loadSavepointWithHandle(savepointFileOrDirectory String, classLoader ClassLoader) : Tuple2<Savepoint,StreamStateHandle> in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStore | From | To |