31310cd657381d4035cda9659d737ed440f90d26
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 14
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Return Type | 1 | ||
Change Return Type AbstractRocksDBSnapshot<K,N,S,SD> to KvStateSnapshot<K,N,S,SD,RocksDBStateBackend> in method public snapshot(checkpointId long, timestamp long) : KvStateSnapshot<K,N,S,SD,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
Rename Attribute | 1 | ||
Rename Attribute dbPath : File to basePath : File in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
Rename Parameter | 2 | ||
Rename Parameter dbPath : File to basePath : File in method protected AbstractRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, basePath File, checkpointPath String, options Options) in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To | |
Rename Parameter dbPath : File to basePath : File in method protected AbstractRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, basePath File, checkpointPath String, restorePath String, options Options) in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState | From | To |