6e94cf19736b3b3751abe55cf0f3ce4aa740ef96
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 19
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Class | 2 | ||
| Rename Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBSnapshotOperation renamed to org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation | From | To | |
| Rename Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBRestoreOperation renamed to org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation | From | To | |
| Extract Variable | 1 | ||
| Extract Variable restoreKeyedStateHandles : Collection<KeyedStateHandle> in method public createKeyedStateBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) : AbstractKeyedStateBackend<K> from class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type snapshotOperation : RocksDBSnapshotOperation to snapshotOperation : RocksDBFullSnapshotOperation in method private snapshotFully(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Variable Type restoreOperation : RocksDBRestoreOperation to restoreOperation : RocksDBFullRestoreOperation in method public restore(restoreState Collection<KeyedStateHandle>) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract Method | 2 | ||
| Extract Method private snapshotIncrementally(checkpointId long, checkpointTimestamp long, checkpointStreamFactory CheckpointStreamFactory) : RunnableFuture<KeyedStateHandle> extracted from public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract Method private snapshotFully(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyedStateHandle> extracted from public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter timestamp : long to checkpointTimestamp : long in method private snapshotIncrementally(checkpointId long, checkpointTimestamp long, checkpointStreamFactory CheckpointStreamFactory) : RunnableFuture<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To |