aa21f853ab0380ec1f68ae1d0b7c8d9268da4533
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 23
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public getKey() : String renamed to public getRegistrationKey() : String in class org.apache.flink.runtime.state.SharedStateHandle | From | To | |
| Rename Method private discardState(jobId JobID, executionAttemptID ExecutionAttemptID, checkpointId long, subtaskState SubtaskState) : void renamed to private discardSubtaskState(jobId JobID, executionAttemptID ExecutionAttemptID, checkpointId long, subtaskState SubtaskState) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Method public getKey() : String renamed to public getRegistrationKey() : String in class org.apache.flink.runtime.state.SharedStateRegistryTest.TestSharedState | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method private unregisterSharedStates(sharedStateRegistry SharedStateRegistry) : void from class org.apache.flink.runtime.checkpoint.CompletedCheckpoint to protected doDiscardSharedState() : void from class org.apache.flink.runtime.checkpoint.CompletedCheckpoint.StoredDiscardStrategy | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type stateHandles : Collection<? extends CompositeStateHandle> to stateHandles : Iterable<? extends CompositeStateHandle> in method public unregisterAll(stateHandles Iterable<? extends CompositeStateHandle>) : void in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Change Parameter Type stateHandles : Collection<? extends CompositeStateHandle> to stateHandles : Iterable<? extends CompositeStateHandle> in method public registerAll(stateHandles Iterable<? extends CompositeStateHandle>) : void in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Change Return Type | 3 | ||
| Change Return Type void to int in method public unregister(state SharedStateHandle) : int in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Change Return Type CompletedCheckpointStore to AbstractCompletedCheckpointStore in method protected createCompletedCheckpoints(maxNumberOfCheckpointsToRetain int) : AbstractCompletedCheckpointStore in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStoreITCase | From | To | |
| Change Return Type CompletedCheckpointStore to AbstractCompletedCheckpointStore in method protected createCompletedCheckpoints(maxNumberOfCheckpointsToRetain int) : AbstractCompletedCheckpointStore in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest | From | To | |
| Move Attribute | 2 | ||
| Move Attribute private sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.checkpoint.CheckpointCoordinator to protected sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.checkpoint.AbstractCompletedCheckpointStore | From | To | |
| Move Attribute private sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.checkpoint.CheckpointCoordinator to package sharedStateRegistry : SharedStateRegistry from class org.apache.flink.runtime.checkpoint.CompletedCheckpoint.StoredDiscardStrategy | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.runtime.checkpoint.AbstractCompletedCheckpointStore from classes [org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore, org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore, org.apache.flink.runtime.testutils.RecoverableCompletedCheckpointStore] | From | To | |
| Extract Variable | 1 | ||
| Extract Variable newReferenceCount : int in method public unregister(state SharedStateHandle) : int from class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Change Variable Type | 5 | ||
| Change Variable Type store : CompletedCheckpointStore to store : AbstractCompletedCheckpointStore in method public testShutdownDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest | From | To | |
| Change Variable Type store : CompletedCheckpointStore to store : AbstractCompletedCheckpointStore in method public testSuspendDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest | From | To | |
| Change Variable Type entry : SharedStateEntry to entry : SharedStateRegistry.SharedStateEntry in method public unregister(state SharedStateHandle) : int in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Change Variable Type checkpoints : CompletedCheckpointStore to checkpoints : AbstractCompletedCheckpointStore in method public testRecover() : void in class org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStoreITCase | From | To | |
| Change Variable Type entry : SharedStateEntry to entry : SharedStateRegistry.SharedStateEntry in method public getReferenceCount(state SharedStateHandle) : int in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type discardCallback : DiscardCallback to discardCallback : CompletedCheckpointStats.DiscardCallback in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
| Change Attribute Type registeredStates : Map<String,SharedStateEntry> to registeredStates : Map<String,SharedStateRegistry.SharedStateEntry> in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter sharedStateRegistry : SharedStateRegistry to registry : SharedStateRegistry in method protected verifyCheckpointRegistered(taskStates Collection<TaskState>, registry SharedStateRegistry) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest | From | To |