|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public setMetricGroup(metrics TaskIOMetricGroup) : void in class org.apache.flink.streaming.runtime.io.StreamInputProcessor |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method package LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventDispatcher TaskEventDispatcher, initialBackoff int, maxBackoff int, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public instantiateMetrics(metrics TaskIOMetricGroup) : void in class org.apache.flink.runtime.io.network.api.serialization.RecordSerializer |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public setMetricGroup(metrics TaskIOMetricGroup) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public setMetricGroup(metrics TaskIOMetricGroup) : void in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public RemoteInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, connectionId ConnectionID, connectionManager ConnectionManager, initialBackoff int, maxBackoff int, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method package LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventDispatcher TaskEventDispatcher, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public UnknownInputChannel(gate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventDispatcher TaskEventDispatcher, connectionManager ConnectionManager, initialBackoff int, maxBackoff int, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public create(owningTaskName String, jobId JobID, executionId ExecutionAttemptID, igdd InputGateDeploymentDescriptor, networkEnvironment NetworkEnvironment, taskActions TaskActions, metrics TaskIOMetricGroup) : SingleInputGate in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public instantiateMetrics(metrics TaskIOMetricGroup) : void in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public SingleInputGate(owningTaskName String, jobId JobID, executionId ExecutionAttemptID, consumedResultId IntermediateDataSetID, consumedSubpartitionIndex int, numberOfInputChannels int, taskActions TaskActions, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Parameter Type metrics : IOMetricGroup to metrics : TaskIOMetricGroup in method public RemoteInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, connectionId ConnectionID, connectionManager ConnectionManager, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel |
From |
To |