4745d0c0822ba1f1c32568d0c4869cb44fa35426
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 2 | ||
Rename Method package getOldSstFiles() : Map<String,StreamStateHandle> renamed to package getUnregisteredSstFiles() : Map<String,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalKeyedStateHandle | From | To | |
Rename Method package getNewSstFiles() : Map<String,StreamStateHandle> renamed to package getRegisteredSstFiles() : Map<String,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalKeyedStateHandle | From | To | |
Change Parameter Type | 1 | ||
Change Parameter Type value : SharedStateHandle to value : StreamStateHandle in method package SharedStateEntry(value StreamStateHandle) in class org.apache.flink.runtime.state.SharedStateRegistry.SharedStateEntry | From | To | |
Move Method | 1 | ||
Move Method public equals(o Object) : boolean from class org.apache.flink.runtime.state.SharedStateRegistryTest.TestSharedState to public equals(o Object) : boolean from class org.apache.flink.runtime.state.SharedStateRegistryKey | From | To | |
Change Return Type | 2 | ||
Change Return Type String to SharedStateRegistryKey in method public getRegistrationKey() : SharedStateRegistryKey in class org.apache.flink.runtime.state.SharedStateRegistryTest.TestSharedState | From | To | |
Change Return Type SharedStateHandle to StreamStateHandle in method package getState() : StreamStateHandle in class org.apache.flink.runtime.state.SharedStateRegistry.SharedStateEntry | From | To | |
Rename Attribute | 2 | ||
Rename Attribute newSstFiles : Map<String,StreamStateHandle> to unregisteredSstFiles : Map<String,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalKeyedStateHandle | From | To | |
Rename Attribute oldSstFiles : Map<String,StreamStateHandle> to registeredSstFiles : Map<String,StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBIncrementalKeyedStateHandle | From | To | |
Change Attribute Type | 3 | ||
Change Attribute Type registeredStates : Map<String,SharedStateRegistry.SharedStateEntry> to registeredStates : Map<SharedStateRegistryKey,SharedStateRegistry.SharedStateEntry> in class org.apache.flink.runtime.state.SharedStateRegistry | From | To | |
Change Attribute Type state : SharedStateHandle to state : StreamStateHandle in class org.apache.flink.runtime.state.SharedStateRegistry.SharedStateEntry | From | To | |
Change Attribute Type key : String to key : SharedStateRegistryKey in class org.apache.flink.runtime.state.SharedStateRegistryTest.TestSharedState | From | To |