3bf06b9dd3dc66dcfdeccaaa591ace41ea51e343
Files Diff
- Added: 13
- Removed: 0
- Renamed: 0
- Modified: 36
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 2 | ||
| Move And Rename Method private addColumnFamilyToCloseLater(columnFamilyOptions List<ColumnFamilyOptions>, columnFamilyHandle ColumnFamilyHandle) : void from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public addColumnFamilyOptionsToCloseLater(columnFamilyOptions List<ColumnFamilyOptions>, columnFamilyHandle ColumnFamilyHandle) : void from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Move And Rename Method private createColumnFamily(options ColumnFamilyOptions, stateName String) : ColumnFamilyHandle from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public createColumnFamilyDescriptor(stateName String, columnOptions ColumnFamilyOptions) : ColumnFamilyDescriptor from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type instanceSupplier : SupplierWithException<T,Exception> to instanceSupplier : FunctionWithException<Collection<S>,T,Exception> in method public BackendRestorerProcedure(instanceSupplier FunctionWithException<Collection<S>,T,Exception>, backendCloseableRegistry CloseableRegistry, logDescription String) in class org.apache.flink.streaming.api.operators.BackendRestorerProcedure | From | To | |
| Move Method | 7 | ||
| Move Method private createColumnFamilyOptions(stateName String) : ColumnFamilyOptions from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public createColumnFamilyOptions(columnFamilyOptionsFactory Function<String,ColumnFamilyOptions>, stateName String) : ColumnFamilyOptions from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Move Method public getRocksIterator(db RocksDB) : RocksIteratorWrapper from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public getRocksIterator(db RocksDB) : RocksIteratorWrapper from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Move Method private createStateInfo(metaInfoBase RegisteredStateMetaInfoBase) : RocksDbKvStateInfo from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public createStateInfo(metaInfoBase RegisteredStateMetaInfoBase, ttlCompactFiltersManager RocksDbTtlCompactFiltersManager, ttlTimeProvider TtlTimeProvider, db RocksDB, columnFamilyOptionsFactory Function<String,ColumnFamilyOptions>) : RocksDBKeyedStateBackend.RocksDbKvStateInfo from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Move Method package getRocksIterator(db RocksDB, columnFamilyHandle ColumnFamilyHandle) : RocksIteratorWrapper from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public getRocksIterator(db RocksDB, columnFamilyHandle ColumnFamilyHandle) : RocksIteratorWrapper from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Move Method private registerKvStateInformation(columnFamilyName String, stateInfo RocksDbKvStateInfo) : void from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public registerKvStateInformation(kvStateInformation Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo>, nativeMetricMonitor RocksDBNativeMetricMonitor, columnFamilyName String, registeredColumn RocksDBKeyedStateBackend.RocksDbKvStateInfo) : void from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Move Method private openDB(path String, stateColumnFamilyDescriptors List<ColumnFamilyDescriptor>, stateColumnFamilyHandles List<ColumnFamilyHandle>) : RocksDB from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to public openDB(path String, stateColumnFamilyDescriptors List<ColumnFamilyDescriptor>, stateColumnFamilyHandles List<ColumnFamilyHandle>, columnFamilyOptions ColumnFamilyOptions, dbOptions DBOptions) : RocksDB from class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Move Method private checkAndCreateDirectory(directory File) : void from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to private checkAndCreateDirectory(directory File) : void from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder | From | To | |
| Pull Up Attribute | 1 | ||
| Pull Up Attribute private isKeySerializerCompatibilityChecked : boolean from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation to protected isKeySerializerCompatibilityChecked : boolean from class org.apache.flink.contrib.streaming.state.restore.AbstractRocksDBRestoreOperation | From | To | |
| Move Attribute | 4 | ||
| Move Attribute private metricGroup : MetricGroup from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to private metricGroup : MetricGroup from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder | From | To | |
| Move Attribute private enableIncrementalCheckpointing : boolean from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to private enableIncrementalCheckpointing : boolean from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder | From | To | |
| Move Attribute private instanceRocksDBPath : File from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to private instanceRocksDBPath : File from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder | From | To | |
| Move Attribute private localRecoveryConfig : LocalRecoveryConfig from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend to private localRecoveryConfig : LocalRecoveryConfig from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder | From | To | |
| Extract Class | 2 | ||
| Extract Class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder from class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Move Class | 3 | ||
| Move Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation moved to org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation | From | To | |
| Move Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation.RestoredDBInstance moved to org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestoreOperation.RestoredDBInstance | From | To | |
| Move Class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBPriorityQueueSetFactory moved to org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueSetFactory | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type stateInfo : RocksDbKvStateInfo to handle : ColumnFamilyHandle in method private restoreKVStateData() : void in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation | From | To | |
| Change Variable Type stateInfo : RocksDbKvStateInfo to stateCFHandle : RocksDBKeyedStateBackend.RocksDbKvStateInfo in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueSetFactory | From | To | |
| Rename Method | 1 | ||
| Rename Method package doRestore(keyedStateHandles Collection<KeyedStateHandle>) : void renamed to public restore() : RocksDBRestoreResult in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation | From | To | |
| Rename Variable | 3 | ||
| Rename Variable stateInfo : RocksDbKvStateInfo to handle : ColumnFamilyHandle in method private restoreKVStateData() : void in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation | From | To | |
| Rename Variable stateInfo : RocksDbKvStateInfo to stateCFHandle : RocksDBKeyedStateBackend.RocksDbKvStateInfo in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueSetFactory | From | To | |
| Rename Variable stubState : ValueStateDescriptor<String> to stubState1 : ValueStateDescriptor<String> in method public testCorrectMergeOperatorSet() : void in class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest | From | To | |
| Change Return Type | 3 | ||
| Change Return Type RocksDbKvStateInfo to RocksDBKeyedStateBackend.RocksDbKvStateInfo in method public createStateInfo(metaInfoBase RegisteredStateMetaInfoBase, ttlCompactFiltersManager RocksDbTtlCompactFiltersManager, ttlTimeProvider TtlTimeProvider, db RocksDB, columnFamilyOptionsFactory Function<String,ColumnFamilyOptions>) : RocksDBKeyedStateBackend.RocksDbKvStateInfo in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Change Return Type ColumnFamilyHandle to ColumnFamilyDescriptor in method public createColumnFamilyDescriptor(stateName String, columnOptions ColumnFamilyOptions) : ColumnFamilyDescriptor in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To | |
| Change Return Type void to RocksDBRestoreResult in method public restore() : RocksDBRestoreResult in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.contrib.streaming.state.restore.AbstractRocksDBRestoreOperation from classes [org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation] | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute currentKvStates : List<RocksDbKvStateInfo> to currentStateHandleKVStateColumnFamilies : List<ColumnFamilyHandle> in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type backendSupplier : SupplierWithException<OperatorStateBackend,Exception> to backendSupplier : FunctionWithException<Collection<OperatorStateHandle>,OperatorStateBackend,Exception> in class org.apache.flink.streaming.api.operators.BackendRestorerProcedureTest | From | To | |
| Change Attribute Type currentKvStates : List<RocksDbKvStateInfo> to currentStateHandleKVStateColumnFamilies : List<ColumnFamilyHandle> in class org.apache.flink.contrib.streaming.state.restore.RocksDBFullRestoreOperation | From | To | |
| Change Attribute Type instanceSupplier : SupplierWithException<T,Exception> to instanceSupplier : FunctionWithException<Collection<S>,T,Exception> in class org.apache.flink.streaming.api.operators.BackendRestorerProcedure | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter options : ColumnFamilyOptions to columnOptions : ColumnFamilyOptions in method public createColumnFamilyDescriptor(stateName String, columnOptions ColumnFamilyOptions) : ColumnFamilyDescriptor in class org.apache.flink.contrib.streaming.state.RocksDBOperationUtils | From | To |