flink f98a7a8558deb155c6a20bb7b9687feb949514f7

f98a7a8558deb155c6a20bb7b9687feb949514f7

Files Diff

Added: 1
Removed: 0
Renamed: 0
Modified: 29

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Merge Attribute	1
Merge Attribute [numBytesInRateLocal : Meter, numBytesInRateRemote : Meter] to numBytesInRate : Meter in class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup	From	To
Rename Method	3
Rename Method public getNumBytesInLocal() : long renamed to public getNumBytesIn() : long in class org.apache.flink.runtime.executiongraph.IOMetrics	From	To
Rename Method public isNumBytesInLocalComplete() : boolean renamed to public isNumBytesInComplete() : boolean in class org.apache.flink.runtime.rest.handler.util.MutableIOMetrics	From	To
Rename Method public getNumBytesInLocalCounter() : Counter renamed to public getNumBytesInCounter() : Counter in class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup	From	To
Change Parameter Type	6
Change Parameter Type metrics : TaskIOMetricGroup to metrics : InputChannelMetrics in method public RemoteInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, connectionId ConnectionID, connectionManager ConnectionManager, initialBackOff int, maxBackoff int, metrics InputChannelMetrics) in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel	From	To
Change Parameter Type metrics : TaskIOMetricGroup to metrics : InputChannelMetrics in method public LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, initialBackoff int, maxBackoff int, metrics InputChannelMetrics) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel	From	To
Change Parameter Type metrics : TaskIOMetricGroup to metrics : InputChannelMetrics in method public LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, metrics InputChannelMetrics) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel	From	To
Change Parameter Type metrics : TaskIOMetricGroup to metrics : InputChannelMetrics in method public RemoteInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, connectionId ConnectionID, connectionManager ConnectionManager, metrics InputChannelMetrics) in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel	From	To
Change Parameter Type metrics : TaskIOMetricGroup to metrics : InputChannelMetrics in method public UnknownInputChannel(gate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, connectionManager ConnectionManager, initialBackoff int, maxBackoff int, metrics InputChannelMetrics) in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel	From	To
Change Parameter Type metrics : TaskIOMetricGroup to metrics : InputChannelMetrics in method public create(owningTaskName String, jobId JobID, igdd InputGateDeploymentDescriptor, networkEnvironment NetworkEnvironment, taskEventPublisher TaskEventPublisher, taskActions TaskActions, metrics InputChannelMetrics, numBytesInCounter Counter) : SingleInputGate in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate	From	To
Move Method	3
Move Method public getNumBuffersInRemoteCounter() : Counter from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup to package getNumBuffersInRemoteCounter() : Counter from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Method public getNumBuffersInLocalCounter() : Counter from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup to package getNumBuffersInLocalCounter() : Counter from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Method public getNumBytesInRemoteCounter() : Counter from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup to package getNumBytesInRemoteCounter() : Counter from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute	12
Move Attribute public IO_NUM_BYTES_IN_REMOTE_RATE : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BYTES_IN_REMOTE_RATE : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute public IO_NUM_BYTES_IN_REMOTE : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BYTES_IN_REMOTE : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute public IO_NUM_BUFFERS_IN_LOCAL : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BUFFERS_IN_LOCAL : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute public IO_NUM_BUFFERS_IN_LOCAL_RATE : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BUFFERS_IN_LOCAL_RATE : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute private numBytesInLocal : Counter from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup to private numBytesInLocal : Counter from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute private numBuffersInRemote : Counter from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup to private numBuffersInRemote : Counter from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute private numBuffersInLocal : Counter from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup to private numBuffersInLocal : Counter from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute public IO_NUM_BYTES_IN_LOCAL : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BYTES_IN_LOCAL : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute public IO_NUM_BUFFERS_IN_REMOTE_RATE : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BUFFERS_IN_REMOTE_RATE : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute private numBytesInRemote : Counter from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup to private numBytesInRemote : Counter from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute public IO_NUM_BUFFERS_IN_REMOTE : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BUFFERS_IN_REMOTE : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Move Attribute public IO_NUM_BYTES_IN_LOCAL_RATE : String from class org.apache.flink.runtime.metrics.MetricNames to private IO_NUM_BYTES_IN_LOCAL_RATE : String from class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics	From	To
Extract Class	2
Extract Class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics from class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup	From	To
Extract Class org.apache.flink.runtime.io.network.partition.consumer.InputChannelMetrics from class org.apache.flink.runtime.metrics.MetricNames	From	To
Merge Variable	2
Merge Variable [bytesInLocal : long, bytesInRemote : long] to bytesIn : long in method public testHandleRequest() : void in class org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandlerTest	From	To
Merge Variable [bytesInLocal : long, bytesInRemote : long] to bytesIn : long in method public testHandleRequest() : void in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandlerTest	From	To
Rename Attribute	3
Rename Attribute numBytesInLocalComplete : boolean to numBytesInComplete : boolean in class org.apache.flink.runtime.rest.handler.util.MutableIOMetrics	From	To
Rename Attribute numBytesInLocal : Counter to numBytesIn : Counter in class org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup	From	To
Rename Attribute numBytesInLocal : long to numBytesIn : long in class org.apache.flink.runtime.executiongraph.IOMetrics	From	To
Change Attribute Type	1
Change Attribute Type metrics : TaskIOMetricGroup to metrics : InputChannelMetrics in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel	From	To
Rename Parameter	2
Rename Parameter bytesLocalIn : Meter to bytesIn : Meter in method public IOMetrics(recordsIn Meter, recordsOut Meter, bytesIn Meter, bytesOut Meter) in class org.apache.flink.runtime.executiongraph.IOMetrics	From	To
Rename Parameter numBytesInLocal : long to numBytesIn : long in method public IOMetrics(numBytesIn long, numBytesOut long, numRecordsIn long, numRecordsOut long) in class org.apache.flink.runtime.executiongraph.IOMetrics	From	To

f98a7a8558deb155c6a20bb7b9687feb949514f7

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: