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