70f4141369850dcc16efe3ddfe71618ea8cda304
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Inline Method | 1 | ||
| Move And Inline Method public resolveKvStateCompatibility(restoredStateMetaInfoSnapshot StateMetaInfoSnapshot, newNamespaceSerializer TypeSerializer<N>, newStateDescriptor StateDescriptor<?,S>, snapshotTransformer StateSnapshotTransformer<S>) : RegisteredKeyValueStateBackendMetaInfo<N,S> moved from class org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo to class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend & inlined to private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>, snapshotTransformer StateSnapshotTransformer<V>) : StateTable<K,N,V> | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type stateDesc : StateDescriptor<?,S> to stateDesc : StateDescriptor<S,SV> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<SV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Parameter Type snapshotTransformer : StateSnapshotTransformer<S> to snapshotTransformer : StateSnapshotTransformer<SV> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<SV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Rename Variable | 1 | ||
| Rename Variable stateName : String to stateSerializer : TypeSerializer<SV> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<SV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,S>> to Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<SV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type stateName : String to stateSerializer : TypeSerializer<SV> in method private tryRegisterKvStateInformation(stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, snapshotTransformer StateSnapshotTransformer<SV>) : Tuple2<ColumnFamilyHandle,RegisteredKeyValueStateBackendMetaInfo<N,SV>> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Extract Variable | 1 | ||
| Extract Variable newStateSerializer : TypeSerializer<V> in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>, snapshotTransformer StateSnapshotTransformer<V>) : StateTable<K,N,V> from class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend | From | To | |
| Extract Method | 1 | ||
| Extract Method private migrateStateIfNecessary(newMetaInfo RegisteredKeyValueStateBackendMetaInfo<N,SV>, stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, stateSerializer TypeSerializer<SV>, stateInfo Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : RegisteredKeyValueStateBackendMetaInfo<N,SV> 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 |