e62a7eabe34da42e4cb56d1b14905a3b9e9c9bd4
Files Diff
- Added: 7
- Removed: 0
- Renamed: 0
- Modified: 25
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Parameterize Variable | 2 | ||
| Parameterize Variable stateInfo : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to registeredColumn : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in method private registerKvStateInformation(columnFamilyName String, registeredColumn Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Parameterize Variable metaInfoTuple : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> to registeredColumn : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in method private registerKvStateInformation(columnFamilyName String, registeredColumn Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract Method | 2 | ||
| Extract Method private registerKvStateInformation(columnFamilyName String, registeredColumn Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : void extracted from private tryRegisterKvStateInformation(stateDesc StateDescriptor<?,S>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<S>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,S>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract Method private registerKvStateInformation(columnFamilyName String, registeredColumn Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : void extracted from private tryRegisterPriorityQueueMetaInfo(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract And Move Method | 2 | ||
| Extract And Move Method private registerKvStateInformation(columnFamilyName String, registeredColumn Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : void extracted from private restoreKVStateMetaData() : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBFullRestoreOperation & moved to class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract And Move Method private registerKvStateInformation(columnFamilyName String, registeredColumn Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : void extracted from private getOrRegisterColumnFamilyHandle(columnFamilyDescriptor ColumnFamilyDescriptor, columnFamilyHandle ColumnFamilyHandle, stateMetaInfoSnapshot StateMetaInfoSnapshot) : ColumnFamilyHandle in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalRestoreOperation & moved to class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter stateName : String to columnFamilyName : String in method private registerKvStateInformation(columnFamilyName String, registeredColumn Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To |