ab014ef94e0e9137ac6f8f41dae385ff71e8ba5b
Files Diff
- Added: 22
- Removed: 0
- Renamed: 0
- Modified: 33
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Subclass | 1 | ||
| Extract Subclass org.apache.flink.runtime.state.heap.NestedMapsStateTable from class org.apache.flink.runtime.state.heap.StateTable | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type metaInfo : RegisteredBackendStateMetaInfo<N,ST> to metaInfo : RegisteredBackendStateMetaInfo<N,S> in method public setMetaInfo(metaInfo RegisteredBackendStateMetaInfo<N,S>) : void in class org.apache.flink.runtime.state.heap.StateTable | From | To | |
| Change Parameter Type map : Map<N,Map<K,ST>> to map : Map<N,Map<K,S>> in method private setMapForKeyGroup(keyGroupId int, map Map<N,Map<K,S>>) : void in class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To | |
| Push Down Attribute | 1 | ||
| Push Down Attribute private keyGroupOffset : int from class org.apache.flink.runtime.state.heap.StateTable to private keyGroupOffset : int from class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To | |
| Move Attribute | 3 | ||
| Move Attribute private foldFunction : FoldFunction<T,ACC> from class org.apache.flink.runtime.state.heap.HeapFoldingState to private foldFunction : FoldFunction<T,ACC> from class org.apache.flink.runtime.state.heap.HeapFoldingState.FoldTransformation | From | To | |
| Move Attribute private reduceFunction : ReduceFunction<V> from class org.apache.flink.runtime.state.heap.HeapReducingState to private reduceFunction : ReduceFunction<V> from class org.apache.flink.runtime.state.heap.HeapReducingState.ReduceTransformation | From | To | |
| Move Attribute private aggFunction : AggregateFunction<IN,ACC,OUT> from class org.apache.flink.runtime.state.heap.HeapAggregatingState to private aggFunction : AggregateFunction<IN,ACC,OUT> from class org.apache.flink.runtime.state.heap.HeapAggregatingState.AggregateTransformation | From | To | |
| Extract Class | 3 | ||
| Extract Class org.apache.flink.runtime.state.heap.HeapReducingState.ReduceTransformation from class org.apache.flink.runtime.state.heap.HeapReducingState | From | To | |
| Extract Class org.apache.flink.runtime.state.heap.HeapFoldingState.FoldTransformation from class org.apache.flink.runtime.state.heap.HeapFoldingState | From | To | |
| Extract Class org.apache.flink.runtime.state.heap.HeapAggregatingState.AggregateTransformation from class org.apache.flink.runtime.state.heap.HeapAggregatingState | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.contrib.streaming.state.RocksDBStateBackendTest.BlockerCheckpointStreamFactory moved to org.apache.flink.runtime.util.BlockerCheckpointStreamFactory | From | To | |
| Extract Variable | 1 | ||
| Extract Variable map : StateTable<K,N,ArrayList<V>> in method public add(value V) : void from class org.apache.flink.runtime.state.heap.HeapListState | From | To | |
| Change Variable Type | 6 | ||
| Change Variable Type stateTable : StateTable to stateTable : StateTable<?,?,?> in method protected testConcurrentMapIfQueryable() : void in class org.apache.flink.runtime.state.StateBackendTestBase | From | To | |
| Change Variable Type namespaceMap : Map<N,Map<K,ArrayList<V>>> to namespace : N in method public add(value V) : void in class org.apache.flink.runtime.state.heap.HeapListState | From | To | |
| Change Variable Type namespaceMap : Map<N,Map<K,ACC>> to namespace : N in method public add(value IN) : void in class org.apache.flink.runtime.state.heap.HeapAggregatingState | From | To | |
| Extract Method | 12 | ||
| Extract Method protected windowSize() : int extracted from public doTestTumblingTimeWindowWithKVState(maxParallelism int) : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase | From | To | |
| Extract Method protected windowSlide() : int extracted from public testSlidingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase | From | To | |
| Extract Method protected windowSlide() : int extracted from public testPreAggregatedSlidingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase | From | To | |
| Extract Method protected windowSize() : int extracted from public testSlidingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase | From | To | |
| Extract Method protected windowSize() : int extracted from public testTumblingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase | From | To | |
| Extract Method public bitMix(in int) : int extracted from public murmurHash(code int) : int in class org.apache.flink.util.MathUtils | From | To | |
| Extract Method private checkConcurrentStateTable(stateTable StateTable<?,?,?>, numberOfKeyGroups int) : void extracted from protected testConcurrentMapIfQueryable() : void in class org.apache.flink.runtime.state.StateBackendTestBase | From | To | |
| Extract Method protected windowSize() : int extracted from public testPreAggregatedTumblingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase | From | To | |
| Extract Method protected windowSize() : int extracted from public testPreAggregatedSlidingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase | From | To | |
| Push Down Method | 3 | ||
| Push Down Method public get(index int) : Map<N,Map<K,ST>> from class org.apache.flink.runtime.state.heap.StateTable to package getMapForKeyGroup(keyGroupIndex int) : Map<N,Map<K,S>> from class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To | |
| Push Down Method private indexToOffset(index int) : int from class org.apache.flink.runtime.state.heap.StateTable to private indexToOffset(index int) : int from class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To | |
| Push Down Method public set(index int, map Map<N,Map<K,ST>>) : void from class org.apache.flink.runtime.state.heap.StateTable to private setMapForKeyGroup(keyGroupId int, map Map<N,Map<K,S>>) : void from class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To | |
| Pull Up Method | 3 | ||
| Pull Up Method private createKeyedBackend() : HeapKeyedStateBackend<String> from class org.apache.flink.runtime.state.heap.HeapAggregatingStateTest to public createKeyedBackend() : HeapKeyedStateBackend<String> from class org.apache.flink.runtime.state.heap.HeapStateBackendTestBase | From | To | |
| Pull Up Method private createKeyedBackend() : HeapKeyedStateBackend<String> from class org.apache.flink.runtime.state.heap.HeapReducingStateTest to public createKeyedBackend() : HeapKeyedStateBackend<String> from class org.apache.flink.runtime.state.heap.HeapStateBackendTestBase | From | To | |
| Pull Up Method private createKeyedBackend() : HeapKeyedStateBackend<String> from class org.apache.flink.runtime.state.heap.HeapListStateTest to public createKeyedBackend() : HeapKeyedStateBackend<String> from class org.apache.flink.runtime.state.heap.HeapStateBackendTestBase | From | To | |
| Inline Method | 1 | ||
| Inline Method private restoreHeapState(stateSnapshot AbstractMemStateSnapshot<K,?,?,?,?>) : RestoredState inlined to private restoreOldSavepointKeyedState(stateHandles Collection<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend | From | To | |
| Rename Variable | 2 | ||
| Rename Variable namespaceMap : Map<N,Map<K,ArrayList<V>>> to namespace : N in method public add(value V) : void in class org.apache.flink.runtime.state.heap.HeapListState | From | To | |
| Rename Variable namespaceMap : Map<N,Map<K,ACC>> to namespace : N in method public add(value IN) : void in class org.apache.flink.runtime.state.heap.HeapAggregatingState | From | To | |
| Change Return Type | 3 | ||
| Change Return Type Map<N,Map<K,ST>> to Map<N,Map<K,S>> in method package getMapForKeyGroup(keyGroupIndex int) : Map<N,Map<K,S>> in class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To | |
| Change Return Type RegisteredBackendStateMetaInfo<N,ST> to RegisteredBackendStateMetaInfo<N,S> in method public getMetaInfo() : RegisteredBackendStateMetaInfo<N,S> in class org.apache.flink.runtime.state.heap.StateTable | From | To | |
| Change Return Type TypeSerializer<ST> to TypeSerializer<S> in method public getStateSerializer() : TypeSerializer<S> in class org.apache.flink.runtime.state.heap.StateTable | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.runtime.state.heap.HeapStateBackendTestBase from classes [org.apache.flink.runtime.state.heap.HeapAggregatingStateTest, org.apache.flink.runtime.state.heap.HeapListStateTest, org.apache.flink.runtime.state.heap.HeapReducingStateTest] | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.runtime.state.heap.InternalKeyContext from classes [org.apache.flink.runtime.state.KeyedStateBackend] | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type stateTables : Map<String,StateTable<K,?,?>> to stateTables : HashMap<String,StateTable<K,?,?>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend | From | To | |
| Change Attribute Type metaInfo : RegisteredBackendStateMetaInfo<N,ST> to metaInfo : RegisteredBackendStateMetaInfo<N,S> in class org.apache.flink.runtime.state.heap.StateTable | From | To | |
| Extract And Move Method | 8 | ||
| Extract And Move Method protected numElementsPerKey() : int extracted from public doTestTumblingTimeWindowWithKVState(maxParallelism int) : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Extract And Move Method protected numKeys() : int extracted from public doTestTumblingTimeWindowWithKVState(maxParallelism int) : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Extract And Move Method protected numElementsPerKey() : int extracted from public testSlidingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Extract And Move Method protected numKeys() : int extracted from public testPreAggregatedTumblingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Extract And Move Method protected numKeys() : int extracted from public testTumblingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Extract And Move Method protected numElementsPerKey() : int extracted from public testTumblingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Extract And Move Method protected numElementsPerKey() : int extracted from public testPreAggregatedSlidingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Extract And Move Method protected numElementsPerKey() : int extracted from public testPreAggregatedTumblingTimeWindow() : void in class org.apache.flink.test.checkpointing.AbstractEventTimeWindowCheckpointingITCase & moved to class org.apache.flink.test.checkpointing.RocksDbBackendEventTimeWindowCheckpointingITCase | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter index : int to keyGroupId : int in method private setMapForKeyGroup(keyGroupId int, map Map<N,Map<K,S>>) : void in class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To | |
| Rename Parameter code : int to in : int in method public bitMix(in int) : int in class org.apache.flink.util.MathUtils | From | To | |
| Rename Parameter index : int to keyGroupIndex : int in method package getMapForKeyGroup(keyGroupIndex int) : Map<N,Map<K,S>> in class org.apache.flink.runtime.state.heap.NestedMapsStateTable | From | To |