f803280bb933d968976e79b9efb5953bed308d96
Files Diff
- Added: 4
- Removed: 6
- Renamed: 0
- Modified: 13
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method private createStateHandlesFromStreamProvider(checkpointStreamWithResultProvider CheckpointStreamWithResultProvider) : SnapshotResult<KeyedStateHandle> renamed to protected callInternal() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable | From | To | |
| Rename Method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> renamed to public snapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy | From | To | |
| Rename Method private materializeStateData(filePath Path) : StreamStateHandle renamed to private uploadLocalFileToCheckpointFs(filePath Path) : StreamStateHandle in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.RocksDBIncrementalSnapshotOperation | From | To | |
| Pull Up Method | 1 | ||
| Pull Up Method package stop() : void from class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.RocksDBIncrementalSnapshotOperation to private closeSnapshotIO() : void from class org.apache.flink.runtime.state.AsyncSnapshotCallable | From | To | |
| Move And Inline Method | 2 | ||
| Move And Inline Method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> moved from class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy to class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend & inlined to public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> | From | To | |
| Move And Inline Method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> moved from class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy to class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend & inlined to public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> | From | To | |
| Pull Up Attribute | 2 | ||
| Pull Up Attribute private LOG : Logger from class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy to private LOG : Logger from class org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase | From | To | |
| Pull Up Attribute private snapshotCloseableRegistry : CloseableRegistry from class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.RocksDBFullSnapshotCallable to private snapshotCloseableRegistry : CloseableRegistry from class org.apache.flink.runtime.state.AsyncSnapshotCallable | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.RocksDBFullSnapshotCallable renamed to org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable | From | To | |
| Extract Superclass | 3 | ||
| Extract Superclass org.apache.flink.runtime.state.AbstractSnapshotStrategy from classes [org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy] | From | To | |
| Extract Superclass org.apache.flink.contrib.streaming.state.snapshot.RocksDBSnapshotStrategyBase from classes [org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy, org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy] | From | To | |
| Extract Superclass org.apache.flink.runtime.state.AsyncSnapshotCallable from classes [org.apache.flink.contrib.streaming.state.snapshot.RocksFullSnapshotStrategy.SnapshotAsynchronousPartCallable, org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.RocksDBIncrementalSnapshotOperation] | From | To |