4c4ce451fcaa6055c97dd4fdd55ae1c0239ce5cf
Files Diff
- Added: 5
- Removed: 2
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public testThreadPoolExceptionRethrow() : void renamed to public testMultiThreadRestoreThreadPoolExceptionRethrow() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateDownloaderTest | From | To | |
| Rename Method public setNumberOfRestoringThreads(numberOfRestoringThreads int) : void renamed to public setNumberOfTransferingThreads(numberOfTransferingThreads int) : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To | |
| Rename Method public getNumberOfRestoringThreads() : int renamed to public getNumberOfTransferingThreads() : int in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To | |
| Move And Inline Method | 2 | ||
| Move And Inline Method protected registerCloseableForCancellation(toRegister Closeable) : void moved from class org.apache.flink.runtime.state.AsyncSnapshotCallable to class org.apache.flink.runtime.state.AsyncSnapshotCallableTest.TestAsyncSnapshotCallable & inlined to protected callInternal() : String | From | To | |
| Move And Inline Method protected unregisterCloseableFromCancellation(toUnregister Closeable) : boolean moved from class org.apache.flink.runtime.state.AsyncSnapshotCallable to class org.apache.flink.runtime.state.AsyncSnapshotCallableTest.TestAsyncSnapshotCallable & inlined to protected callInternal() : String | From | To | |
| Move Method | 1 | ||
| Move Method private uploadLocalFileToCheckpointFs(filePath Path) : StreamStateHandle from class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.RocksDBIncrementalSnapshotOperation to private uploadLocalFileToCheckpointFs(filePath Path, checkpointStreamFactory CheckpointStreamFactory, closeableRegistry CloseableRegistry) : StreamStateHandle from class org.apache.flink.contrib.streaming.state.RocksDBStateUploader | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private READ_BUFFER_SIZE : int from class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.RocksDBIncrementalSnapshotOperation to private READ_BUFFER_SIZE : int from class org.apache.flink.contrib.streaming.state.RocksDBStateUploader | From | To | |
| Rename Class | 2 | ||
| Rename Class org.apache.flink.contrib.streaming.state.RocksDBStateDataTransferTest renamed to org.apache.flink.contrib.streaming.state.RocksDBStateDownloaderTest | From | To | |
| Rename Class org.apache.flink.contrib.streaming.state.RocksDbStateDataTransfer renamed to org.apache.flink.contrib.streaming.state.RocksDBStateDownloader | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.contrib.streaming.state.RocksDBStateDataTransfer from classes [org.apache.flink.contrib.streaming.state.RocksDBStateDownloader] | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute numberOfRestoringThreads : int to numberOfTransferingThreads : int in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To | |
| Rename Attribute restoringThreadNum : int to numberOfTransferingThreads : int in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Rename Attribute UNDEFINED_NUMBER_OF_RESTORING_THREADS : int to UNDEFINED_NUMBER_OF_TRANSFERING_THREADS : int in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To | |
| Extract Method | 1 | ||
| Extract Method private createUploadFilePaths(fileStatuses FileStatus[], sstFiles Map<StateHandleID,StreamStateHandle>, sstFilePaths Map<StateHandleID,Path>, miscFilePaths Map<StateHandleID,Path>) : void extracted from private uploadSstFiles(sstFiles Map<StateHandleID,StreamStateHandle>, miscFiles Map<StateHandleID,StreamStateHandle>) : void in class org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.RocksDBIncrementalSnapshotOperation | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter numberOfRestoringThreads : int to numberOfTransferingThreads : int in method public setNumberOfTransferingThreads(numberOfTransferingThreads int) : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend | From | To | |
| Rename Parameter restoringThreadNum : int to numberOfTransferingThreads : int in method public RocksDBKeyedStateBackend(operatorIdentifier String, userCodeClassLoader ClassLoader, instanceBasePath File, dbOptions DBOptions, columnFamilyOptions ColumnFamilyOptions, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, executionConfig ExecutionConfig, enableIncrementalCheckpointing boolean, numberOfTransferingThreads int, localRecoveryConfig LocalRecoveryConfig, priorityQueueStateType RocksDBStateBackend.PriorityQueueStateType, ttlTimeProvider TtlTimeProvider, metricOptions RocksDBNativeMetricOptions, metricGroup MetricGroup) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To |