aedc4f5dcca95820969af694e6d2a71a1fe698bd
Files Diff
- Added: 7
- Removed: 3
- Renamed: 0
- Modified: 13
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type partition : ResultPartition to partitions : ResultPartition[] in method public registerQueueLengthMetrics(parent MetricGroup, partitions ResultPartition[]) : void in class org.apache.flink.runtime.io.network.metrics.ResultPartitionMetrics | From | To | |
| Change Parameter Type gate : SingleInputGate to gates : SingleInputGate[] in method public registerQueueLengthMetrics(parent MetricGroup, gates SingleInputGate[]) : void in class org.apache.flink.runtime.io.network.metrics.InputGateMetrics | From | To | |
| Move Class | 3 | ||
| Move Class org.apache.flink.runtime.io.network.partition.ResultPartitionMetrics moved to org.apache.flink.runtime.io.network.metrics.ResultPartitionMetrics | From | To | |
| Move Class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics moved to org.apache.flink.runtime.io.network.metrics.InputChannelMetrics | From | To | |
| Move Class org.apache.flink.runtime.io.network.partition.consumer.InputGateMetrics moved to org.apache.flink.runtime.io.network.metrics.InputGateMetrics | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public createResultPartitionWriters(taskName String, jobId JobID, executionId ExecutionAttemptID, taskActions TaskActions, partitionConsumableNotifier ResultPartitionConsumableNotifier, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, outputGroup MetricGroup, buffersGroup MetricGroup) : ResultPartition[] 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, networkEnvironment NetworkEnvironment, 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.NetworkEnvironment | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter gate : SingleInputGate to gates : SingleInputGate[] in method public registerQueueLengthMetrics(parent MetricGroup, gates SingleInputGate[]) : void in class org.apache.flink.runtime.io.network.metrics.InputGateMetrics | From | To | |
| Rename Parameter partition : ResultPartition to partitions : ResultPartition[] in method public registerQueueLengthMetrics(parent MetricGroup, partitions ResultPartition[]) : void in class org.apache.flink.runtime.io.network.metrics.ResultPartitionMetrics | From | To | |
| Rename Parameter group : MetricGroup to parent : MetricGroup in method public registerQueueLengthMetrics(parent MetricGroup, partitions ResultPartition[]) : void in class org.apache.flink.runtime.io.network.metrics.ResultPartitionMetrics | From | To | |
| Rename Parameter group : MetricGroup to parent : MetricGroup in method public registerQueueLengthMetrics(parent MetricGroup, gates SingleInputGate[]) : void in class org.apache.flink.runtime.io.network.metrics.InputGateMetrics | From | To |