edae79340dd486915d25109cbdc1485accae665a
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Attribute | 1 | ||
| Rename Attribute backingStateBackend : AbstractStateBackend to nonPartitionedStateBackend : AbstractStateBackend in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To | |
| Extract Method | 1 | ||
| Extract Method public validateAndNormalizeUri(checkpointDataUri URI) : Path extracted from public FsStateBackend(checkpointDataUri URI, fileStateSizeThreshold int) in class org.apache.flink.runtime.state.filesystem.FsStateBackend | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type checkpointDirectory : String to checkpointDirectory : Path in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter backingStateBackend : AbstractStateBackend to nonPartitionedStateBackend : AbstractStateBackend in method public RocksDBStateBackend(checkpointDataUri URI, nonPartitionedStateBackend AbstractStateBackend) in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To |