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