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 |