191deabeb963046689b789322cea40623a515b4e
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type parent : MetricGroup to parents : MetricGroup... in method public InputChannelMetrics(parents MetricGroup...) in class org.apache.flink.runtime.io.network.metrics.InputChannelMetrics | From | To | |
| Rename Variable | 1 | ||
| Rename Variable buffersGroup : MetricGroup to taskShuffleContext : ShuffleIOOwnerContext in method public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, slotAllocationId AllocationID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, memManager MemoryManager, ioManager IOManager, shuffleEnvironment ShuffleEnvironment<?,?>, kvStateService KvStateService, bcVarManager BroadcastVariableManager, taskEventDispatcher TaskEventDispatcher, taskStateManager TaskStateManager, taskManagerActions TaskManagerActions, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, aggregateManager GlobalAggregateManager, blobService BlobCacheService, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Merge Parameter | 1 | ||
| Merge Parameter [ownerName : String, executionAttemptID : ExecutionAttemptID] to ownerContext : ShuffleIOOwnerContext in method public createInputGates(ownerContext ShuffleIOOwnerContext, partitionProducerStateProvider PartitionProducerStateProvider, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>) : Collection<SingleInputGate> in class org.apache.flink.runtime.io.network.NettyShuffleEnvironment | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type buffersGroup : MetricGroup to taskShuffleContext : ShuffleIOOwnerContext in method public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, slotAllocationId AllocationID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, memManager MemoryManager, ioManager IOManager, shuffleEnvironment ShuffleEnvironment<?,?>, kvStateService KvStateService, bcVarManager BroadcastVariableManager, taskEventDispatcher TaskEventDispatcher, taskStateManager TaskStateManager, taskManagerActions TaskManagerActions, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, aggregateManager GlobalAggregateManager, blobService BlobCacheService, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public registerLegacyNetworkMetrics(metricGroup MetricGroup, producedPartitions ResultPartitionWriter[], inputGates InputGate[]) : void extracted from public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, slotAllocationId AllocationID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, memManager MemoryManager, ioManager IOManager, shuffleEnvironment ShuffleEnvironment<?,?>, kvStateService KvStateService, bcVarManager BroadcastVariableManager, taskEventDispatcher TaskEventDispatcher, taskStateManager TaskStateManager, taskManagerActions TaskManagerActions, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, aggregateManager GlobalAggregateManager, blobService BlobCacheService, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task & moved to class org.apache.flink.runtime.io.network.NettyShuffleEnvironment | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter parent : MetricGroup to parents : MetricGroup... in method public InputChannelMetrics(parents MetricGroup...) in class org.apache.flink.runtime.io.network.metrics.InputChannelMetrics | From | To |