78f2a15867734055a9712ea3a27f54d9bed3e43b
Files Diff
- Added: 5
- Removed: 0
- Renamed: 0
- Modified: 37
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getPartitionManager() : ResultPartitionManager renamed to public getResultPartitionManager() : ResultPartitionManager in class org.apache.flink.runtime.io.network.NetworkEnvironment | From | To | |
| Move Method | 1 | ||
| Move Method public testStartupWhenNetworkStackFailsToInitialize() : void from class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest to public testStartupWhenNetworkStackFailsToInitialize() : void from class org.apache.flink.runtime.taskmanager.TaskManagerStartupTest | From | To | |
| Inline Method | 1 | ||
| Inline Method public disassociate() : void inlined to public shutdown() : void in class org.apache.flink.runtime.io.network.NetworkEnvironment | From | To | |
| Move And Rename Class | 3 | ||
| Move And Rename Class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerPartitionStateChecker moved and renamed to org.apache.flink.runtime.taskmanager.ActorGatewayPartitionStateChecker | From | To | |
| Move And Rename Class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerKvStateRegistryListener moved and renamed to org.apache.flink.runtime.taskmanager.ActorGatewayKvStateRegistryListener | From | To | |
| Move And Rename Class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerResultPartitionConsumableNotifier moved and renamed to org.apache.flink.runtime.taskmanager.ActorGatewayResultPartitionConsumableNotifier | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute eagerlyDeployConsumers : boolean to doEagerDeployment : boolean in class org.apache.flink.runtime.io.network.partition.ResultPartition | From | To | |
| Rename Attribute taskManager : ActorGateway to owningTask : Task in class org.apache.flink.runtime.taskmanager.ActorGatewayResultPartitionConsumableNotifier | From | To | |
| Rename Attribute partitionManager : ResultPartitionManager to resultPartitionManager : ResultPartitionManager in class org.apache.flink.runtime.io.network.NetworkEnvironment | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type msg : RequestPartitionState to msg : JobManagerMessages.RequestPartitionState in method public triggerPartitionStateCheck(jobId JobID, executionAttemptID ExecutionAttemptID, resultId IntermediateDataSetID, partitionId ResultPartitionID) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayPartitionStateChecker | From | To | |
| Change Variable Type msg : ScheduleOrUpdateConsumers to msg : JobManagerMessages.ScheduleOrUpdateConsumers in method public notifyPartitionConsumable(jobId JobID, partitionId ResultPartitionID) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayResultPartitionConsumableNotifier | From | To | |
| Split Parameter | 1 | ||
| Split Parameter partitionRequestInitialAndMaxBackoff : Tuple2<Integer,Integer> to [initialBackoff : int, maxBackoff : int] in method public UnknownInputChannel(gate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventDispatcher TaskEventDispatcher, connectionManager ConnectionManager, initialBackoff int, maxBackoff int, metrics IOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type taskManager : ActorGateway to owningTask : Task in class org.apache.flink.runtime.taskmanager.ActorGatewayResultPartitionConsumableNotifier | From | To | |
| Split Attribute | 1 | ||
| Split Attribute partitionRequestInitialAndMaxBackoff : Tuple2<Integer,Integer> to [initialBackoff : int, maxBackoff : int] in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter eagerlyDeployConsumers : boolean to doEagerDeployment : boolean in method public ResultPartition(owningTaskName String, jobId JobID, partitionId ResultPartitionID, partitionType ResultPartitionType, doEagerDeployment boolean, numberOfSubpartitions int, partitionManager ResultPartitionManager, partitionConsumableNotifier ResultPartitionConsumableNotifier, ioManager IOManager, defaultIoMode IOMode) in class org.apache.flink.runtime.io.network.partition.ResultPartition | From | To |