1619fa8abe8d605b14ee0ddabcdc86196c50e24a
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method private readStateData(restoreFilePath Path, remoteFileHandle StreamStateHandle) : void renamed to private copyStateDataHandleData(restoreFilePath Path, remoteFileHandle StreamStateHandle) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Rename Method package materializeSnapshot() : KeyedStateHandle renamed to package runSnapshot() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Rename Method private readAllStateData(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void renamed to private transferAllDataFromStateHandles(stateHandleMap Map<StateHandleID,StreamStateHandle>, restoreInstancePath Path) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method private snapshotFully(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<SnapshotResult<KeyedStateHandle>> from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.FullSnapshotStrategy | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type checkpointStreamFactory : CheckpointStreamFactory to checkpointStreamSupplier : SupplierWithException<CheckpointStreamWithResultProvider,Exception> in method package RocksDBFullSnapshotOperation(stateBackend RocksDBKeyedStateBackend<K>, checkpointStreamSupplier SupplierWithException<CheckpointStreamWithResultProvider,Exception>, registry CloseableRegistry) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation | From | To | |
| Change Parameter Type checkpointTimestamp : long to localBackupDirectory : SnapshotDirectory in method private RocksDBIncrementalSnapshotOperation(stateBackend RocksDBKeyedStateBackend<K>, checkpointStreamFactory CheckpointStreamFactory, localBackupDirectory SnapshotDirectory, checkpointId long) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Rename Variable | 1 | ||
| Rename Variable restoreInstancePath : Path to temporaryRestoreInstancePath : Path in method private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Change Return Type | 3 | ||
| Change Return Type KeyGroupsStateHandle to SnapshotResult<KeyedStateHandle> in method public getSnapshotResultStateHandle() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation | From | To | |
| Change Return Type StreamStateHandle to SnapshotResult<StreamStateHandle> in method private materializeMetaData() : SnapshotResult<StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Change Return Type KeyedStateHandle to SnapshotResult<KeyedStateHandle> in method package runSnapshot() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksIteratorWrapper renamed to org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksIteratorForKeysWrapper | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute checkpointStreamFactory : CheckpointStreamFactory to checkpointStreamSupplier : SupplierWithException<CheckpointStreamWithResultProvider,Exception> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation | From | To | |
| Extract Variable | 1 | ||
| Extract Variable firstStateHandle : KeyedStateHandle in method public restore(restoreState Collection<KeyedStateHandle>) : void from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type iteratorWrapper : RocksIteratorWrapper<K> to iteratorWrapper : RocksIteratorForKeysWrapper<K> in method public getKeys(state String, namespace N) : Stream<K> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Variable Type iteratorWrapper : RocksDBKeyedStateBackend.RocksIteratorWrapper<K> to iteratorWrapper : RocksDBKeyedStateBackend.RocksIteratorForKeysWrapper<K> in method package testIteratorHelper(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer, maxKeyGroupNumber int, getKeyFunc Function<Integer,K>) : void in class org.apache.flink.contrib.streaming.state.RocksDBRocksIteratorWrapperTest | From | To | |
| Inline Variable | 1 | ||
| Inline Variable keyedStateHandle : IncrementalKeyedStateHandle in method package restore(restoreStateHandles Collection<KeyedStateHandle>) : void from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Extract Method | 4 | ||
| Extract Method private restoreLocalStateIntoFullInstance(restoreStateHandle IncrementalLocalKeyedStateHandle, columnFamilyDescriptors List<ColumnFamilyDescriptor>, stateMetaInfoSnapshots List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>>) : void extracted from private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Extract Method private restoreKeyGroupsShardWithTemporaryHelperInstance(restoreInstancePath Path, columnFamilyDescriptors List<ColumnFamilyDescriptor>, stateMetaInfoSnapshots List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>>) : void extracted from private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Extract Method private createAndRegisterColumnFamilyDescriptors(stateMetaInfoSnapshots List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?,?>>) : List<ColumnFamilyDescriptor> extracted from private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Extract Method private transferAllStateDataToDirectory(restoreStateHandle IncrementalKeyedStateHandle, dest Path) : void extracted from private restoreInstance(restoreStateHandle IncrementalKeyedStateHandle, hasExtraKeys boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type checkpointStreamFactory : CheckpointStreamFactory to checkpointStreamSupplier : SupplierWithException<CheckpointStreamWithResultProvider,Exception> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation | From | To | |
| Change Attribute Type metaStateHandle : StreamStateHandle to metaStateHandle : SnapshotResult<StreamStateHandle> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter checkpointStreamFactory : CheckpointStreamFactory to checkpointStreamSupplier : SupplierWithException<CheckpointStreamWithResultProvider,Exception> in method package RocksDBFullSnapshotOperation(stateBackend RocksDBKeyedStateBackend<K>, checkpointStreamSupplier SupplierWithException<CheckpointStreamWithResultProvider,Exception>, registry CloseableRegistry) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullSnapshotOperation | From | To | |
| Rename Parameter checkpointTimestamp : long to localBackupDirectory : SnapshotDirectory in method private RocksDBIncrementalSnapshotOperation(stateBackend RocksDBKeyedStateBackend<K>, checkpointStreamFactory CheckpointStreamFactory, localBackupDirectory SnapshotDirectory, checkpointId long) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Rename Parameter streamFactory : CheckpointStreamFactory to primaryStreamFactory : CheckpointStreamFactory in method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.FullSnapshotStrategy | From | To |