5dc8afd4c8bfea1b2aea0eb6f83ffce38bad3955
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 21
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Pull Up Method | 3 | ||
| Pull Up Method public getCurrentKeyGroupIndex() : int from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest.MockInternalKeyContext to public getCurrentKeyGroupIndex() : int from class org.apache.flink.runtime.state.heap.InternalKeyContextImpl | From | To | |
| Pull Up Method public getNumberOfKeyGroups() : int from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest.MockInternalKeyContext to public getNumberOfKeyGroups() : int from class org.apache.flink.runtime.state.heap.InternalKeyContextImpl | From | To | |
| Pull Up Method public getKeyGroupRange() : KeyGroupRange from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest.MockInternalKeyContext to public getKeyGroupRange() : KeyGroupRange from class org.apache.flink.runtime.state.heap.InternalKeyContextImpl | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type stateTable : StateTable<K,N,S> to stateTable : StateTable<Integer,Integer,ArrayList<Integer>> in method private restoreStateTableFromSnapshot(stateTable StateTable<Integer,Integer,ArrayList<Integer>>, snapshot StateSnapshot, keyGroupRange KeyGroupRange) : void in class org.apache.flink.runtime.state.heap.StateTableSnapshotCompatibilityTest | From | To | |
| Change Parameter Type backend : HeapKeyedStateBackend<K> to keyContext : InternalKeyContext<K> in method package HeapRestoreOperation(restoreStateHandles Collection<KeyedStateHandle>, keySerializerProvider StateSerializerProvider<K>, userCodeClassLoader ClassLoader, registeredKVStates Map<String,StateTable<K,?,?>>, registeredPQStates Map<String,HeapPriorityQueueSnapshotRestoreWrapper>, cancelStreamRegistry CloseableRegistry, priorityQueueSetFactory HeapPriorityQueueSetFactory, keyGroupRange KeyGroupRange, numberOfKeyGroups int, snapshotStrategy HeapSnapshotStrategy<K>, keyContext InternalKeyContext<K>) in class org.apache.flink.runtime.state.heap.HeapRestoreOperation | From | To | |
| Rename Variable | 1 | ||
| Rename Variable backend : HeapKeyedStateBackend<K> to keyContext : InternalKeyContext<K> in method public build() : HeapKeyedStateBackend<K> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder | From | To | |
| Pull Up Attribute | 1 | ||
| Pull Up Attribute private keyGroupRange : KeyGroupRange from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest.MockInternalKeyContext to private keyGroupRange : KeyGroupRange from class org.apache.flink.runtime.state.heap.InternalKeyContextImpl | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private currentKey : K from class org.apache.flink.runtime.state.AbstractKeyedStateBackend to private currentKey : K from class org.apache.flink.runtime.state.heap.InternalKeyContextImpl | From | To | |
| Merge Parameter | 1 | ||
| Merge Parameter [numberOfKeyGroups : int, keyGroupRange : KeyGroupRange] to keyContext : InternalKeyContext<K> in method public AbstractKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializerProvider StateSerializerProvider<K>, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, ttlTimeProvider TtlTimeProvider, cancelStreamRegistry CloseableRegistry, keyGroupCompressionDecorator StreamCompressionDecorator, keyContext InternalKeyContext<K>) in class org.apache.flink.runtime.state.AbstractKeyedStateBackend | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.runtime.state.heap.InternalKeyContextImpl from classes [org.apache.flink.runtime.state.heap.CopyOnWriteStateTableTest.MockInternalKeyContext] | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute backend : HeapKeyedStateBackend<K> to keyContext : InternalKeyContext<K> in class org.apache.flink.runtime.state.heap.HeapRestoreOperation | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type backend : HeapKeyedStateBackend<K> to keyContext : InternalKeyContext<K> in method public build() : HeapKeyedStateBackend<K> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type backend : HeapKeyedStateBackend<K> to keyContext : InternalKeyContext<K> in class org.apache.flink.runtime.state.heap.HeapRestoreOperation | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter backend : HeapKeyedStateBackend<K> to keyContext : InternalKeyContext<K> in method package HeapRestoreOperation(restoreStateHandles Collection<KeyedStateHandle>, keySerializerProvider StateSerializerProvider<K>, userCodeClassLoader ClassLoader, registeredKVStates Map<String,StateTable<K,?,?>>, registeredPQStates Map<String,HeapPriorityQueueSnapshotRestoreWrapper>, cancelStreamRegistry CloseableRegistry, priorityQueueSetFactory HeapPriorityQueueSetFactory, keyGroupRange KeyGroupRange, numberOfKeyGroups int, snapshotStrategy HeapSnapshotStrategy<K>, keyContext InternalKeyContext<K>) in class org.apache.flink.runtime.state.heap.HeapRestoreOperation | From | To |