7e0eafa74d81a805d1445fb74e967acaf455e967
Files Diff
- Added: 6
- Removed: 1
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 1 | ||
| Change Return Type StateTableSnapshot to StateSnapshot in method package abstract createSnapshot() : StateSnapshot in class org.apache.flink.runtime.state.heap.StateTable | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private keyGroupOffsets : int[] from class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableSnapshot to private keyGroupOffsets : int[] from class org.apache.flink.runtime.state.KeyGroupPartitioner.PartitioningResult | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.runtime.state.heap.StateTableSnapshot moved and renamed to org.apache.flink.runtime.state.StateSnapshot.KeyGroupPartitionedSnapshot | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute stateTableSize : int to numberOfEntriesInSnapshotData : int in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableSnapshot | From | To | |
| Rename Attribute keyGroupOffsets : int[] to partitionedStateTableSnapshot : StateSnapshot.KeyGroupPartitionedSnapshot in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableSnapshot | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type kvState : Map.Entry<String,StateTableSnapshot> to kvState : Map.Entry<String,StateSnapshot> in method protected performOperation() : SnapshotResult<KeyedStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy.performSnapshot.ioCallable | From | To | |
| Change Variable Type snapshot : StateTableSnapshot to snapshot : StateSnapshot in method public checkCompatibleSerializationFormats() : void in class org.apache.flink.runtime.state.heap.StateTableSnapshotCompatibilityTest | From | To | |
| Change Variable Type cowStateStableSnapshots : Map<String,StateTableSnapshot> to cowStateStableSnapshots : Map<String,StateSnapshot> in method public performSnapshot(checkpointId long, timestamp long, primaryStreamFactory CheckpointStreamFactory, checkpointOptions CheckpointOptions) : RunnableFuture<SnapshotResult<KeyedStateHandle>> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy | From | To | |
| Change Variable Type tableSnapshot : StateTableSnapshot to tableSnapshot : StateSnapshot in method protected releaseResources() : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.HeapSnapshotStrategy.performSnapshot.ioCallable | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.runtime.state.StateSnapshot from classes [org.apache.flink.runtime.state.heap.AbstractStateTableSnapshot] | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type keyGroupOffsets : int[] to partitionedStateTableSnapshot : StateSnapshot.KeyGroupPartitionedSnapshot in class org.apache.flink.runtime.state.heap.CopyOnWriteStateTableSnapshot | From | To |