f1b2b83d639658907bbc521f967e2673c4c866a1
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type newManagedOperatorStates : List<List<Collection<OperatorStateHandle>>> to newManagedOperatorStates : Multimap<OperatorInstanceID,OperatorStateHandle> in method private reDistributePartitionableStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newManagedOperatorStates Multimap<OperatorInstanceID,OperatorStateHandle>, newRawOperatorStates Multimap<OperatorInstanceID,OperatorStateHandle>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Change Parameter Type newRawOperatorStates : List<List<Collection<OperatorStateHandle>>> to newRawOperatorStates : Multimap<OperatorInstanceID,OperatorStateHandle> in method private reDistributePartitionableStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newManagedOperatorStates Multimap<OperatorInstanceID,OperatorStateHandle>, newRawOperatorStates Multimap<OperatorInstanceID,OperatorStateHandle>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Rename Variable | 1 | ||
| Rename Variable subKeyedState : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> to subKeyedStates : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> in method private reDistributeKeyedStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newKeyGroupPartitions List<KeyGroupRange>, newManagedKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>, newRawKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Parameterize Variable | 2 | ||
| Parameterize Variable keyGroupPartitions : List<KeyGroupRange> to newKeyGroupPartitions : List<KeyGroupRange> in method private reDistributeKeyedStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newKeyGroupPartitions List<KeyGroupRange>, newManagedKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>, newRawKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Parameterize Variable operatorIDs : List<OperatorID> to newOperatorIDs : List<OperatorID> in method private reDistributeKeyedStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newKeyGroupPartitions List<KeyGroupRange>, newManagedKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>, newRawKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Extract Method | 2 | ||
| Extract Method private assignTaskStateToExecutionJobVertices(executionJobVertex ExecutionJobVertex, subManagedOperatorState Multimap<OperatorInstanceID,OperatorStateHandle>, subRawOperatorState Multimap<OperatorInstanceID,OperatorStateHandle>, subManagedKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>, subRawKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>, newParallelism int) : void extracted from private assignAttemptState(executionJobVertex ExecutionJobVertex, operatorStates List<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Extract Method private reDistributeKeyedStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newKeyGroupPartitions List<KeyGroupRange>, newManagedKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>, newRawKeyedState Multimap<OperatorInstanceID,KeyedStateHandle>) : void extracted from private assignAttemptState(executionJobVertex ExecutionJobVertex, operatorStates List<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter operatorStates : List<OperatorState> to oldOperatorStates : List<OperatorState> in method private reDistributePartitionableStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newManagedOperatorStates Multimap<OperatorInstanceID,OperatorStateHandle>, newRawOperatorStates Multimap<OperatorInstanceID,OperatorStateHandle>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation | From | To |