fa03e78d3a245b40ceb3efffeb3020853e74e48b
Files Diff
- Added: 6
- Removed: 0
- Renamed: 0
- Modified: 14
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 1 | ||
| Move And Rename Method private validateAndNormalizeUri(checkpointDataUri URI) : Path from class org.apache.flink.runtime.state.filesystem.FsStateBackend to private validatePath(path Path) : Path from class org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type backend : AbstractStateBackend to backend : StateBackend in method public setStateBackend(backend StateBackend) : void in class org.apache.flink.streaming.api.graph.StreamConfig | From | To | |
| Move Method | 1 | ||
| Move Method public loadStateBackendFromConfig(config Configuration, classLoader ClassLoader, logger Logger) : StateBackend from class org.apache.flink.runtime.state.AbstractStateBackend to public loadStateBackendFromConfig(config Configuration, classLoader ClassLoader, logger Logger) : StateBackend from class org.apache.flink.runtime.state.StateBackendLoader | From | To | |
| Rename Variable | 4 | ||
| Rename Variable rocksdbLocalPath : String to rocksdbLocalPaths : String in method public createFromConfig(config Configuration) : RocksDBStateBackend in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory | From | To | |
| Rename Variable fromJob : StateBackend to fromApplication : StateBackend in method private createStateBackend() : StateBackend in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Rename Variable expectedPath : Path to expectedSavepointsPath : Path in method public testLoadFileSystemStateBackend() : void in class org.apache.flink.runtime.state.StateBackendLoadingTest | From | To | |
| Rename Variable checkpointDirURI : String to checkpointDir : String in method public createFromConfig(config Configuration) : FsStateBackend in class org.apache.flink.runtime.state.filesystem.FsStateBackendFactory | From | To | |
| Change Return Type | 1 | ||
| Change Return Type AbstractStateBackend to StateBackend in method public getStateBackend(cl ClassLoader) : StateBackend in class org.apache.flink.streaming.api.graph.StreamConfig | From | To | |
| Move Attribute | 3 | ||
| Move Attribute public MEMORY_STATE_BACKEND_NAME : String from class org.apache.flink.runtime.state.AbstractStateBackend to public MEMORY_STATE_BACKEND_NAME : String from class org.apache.flink.runtime.state.StateBackendLoader | From | To | |
| Move Attribute public FS_STATE_BACKEND_NAME : String from class org.apache.flink.runtime.state.AbstractStateBackend to public FS_STATE_BACKEND_NAME : String from class org.apache.flink.runtime.state.StateBackendLoader | From | To | |
| Move Attribute public ROCKSDB_STATE_BACKEND_NAME : String from class org.apache.flink.runtime.state.AbstractStateBackend to public ROCKSDB_STATE_BACKEND_NAME : String from class org.apache.flink.runtime.state.StateBackendLoader | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.runtime.state.StateBackendLoader from class org.apache.flink.runtime.state.AbstractStateBackend | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend from classes [org.apache.flink.runtime.state.filesystem.FsStateBackend, org.apache.flink.runtime.state.memory.MemoryStateBackend] | From | To | |
| Extract Method | 4 | ||
| Extract Method public isUsingAsynchronousSnapshots() : boolean extracted from public createOperatorStateBackend(env Environment, operatorIdentifier String) : OperatorStateBackend in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Extract Method public isUsingAsynchronousSnapshots() : boolean extracted from public createOperatorStateBackend(env Environment, operatorIdentifier String) : OperatorStateBackend in class org.apache.flink.runtime.state.memory.MemoryStateBackend | From | To | |
| Extract Method public isUsingAsynchronousSnapshots() : boolean extracted from public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend | From | To | |
| Extract Method public isUsingAsynchronousSnapshots() : boolean extracted from public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type asynchronousSnapshots : boolean to asynchronousSnapshots : TernaryBoolean in class org.apache.flink.runtime.state.memory.MemoryStateBackend | From | To | |
| Change Attribute Type asynchronousSnapshots : boolean to asynchronousSnapshots : TernaryBoolean in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public configure(config Configuration) : FsStateBackend extracted from public createFromConfig(config Configuration) : FsStateBackend in class org.apache.flink.runtime.state.filesystem.FsStateBackendFactory & moved to class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To |