|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventDispatcher : TaskEventPublisher in method public start(partitionProvider ResultPartitionProvider, taskEventDispatcher TaskEventPublisher) : void in class org.apache.flink.runtime.io.network.ConnectionManager |
From |
To |
|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public NetworkEnvironment(networkBufferPool NetworkBufferPool, connectionManager ConnectionManager, resultPartitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, partitionRequestInitialBackoff int, partitionRequestMaxBackoff int, networkBuffersPerChannel int, extraNetworkBuffersPerGate int, enableCreditBased boolean) in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, initialBackoff int, maxBackoff int, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method package PartitionRequestServerHandler(partitionProvider ResultPartitionProvider, taskEventPublisher TaskEventPublisher, outboundQueue PartitionRequestQueue, creditBasedEnabled boolean) in class org.apache.flink.runtime.io.network.netty.PartitionRequestServerHandler |
From |
To |
|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public start(partitionProvider ResultPartitionProvider, taskEventPublisher TaskEventPublisher) : void in class org.apache.flink.runtime.io.network.netty.NettyConnectionManager |
From |
To |
|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public UnknownInputChannel(gate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, connectionManager ConnectionManager, initialBackoff int, maxBackoff int, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel |
From |
To |
|
Change Parameter Type taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method package NettyProtocol(partitionProvider ResultPartitionProvider, taskEventPublisher TaskEventPublisher, creditBasedEnabled boolean) in class org.apache.flink.runtime.io.network.netty.NettyProtocol |
From |
To |
|
Rename Parameter taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public NetworkEnvironment(networkBufferPool NetworkBufferPool, connectionManager ConnectionManager, resultPartitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, partitionRequestInitialBackoff int, partitionRequestMaxBackoff int, networkBuffersPerChannel int, extraNetworkBuffersPerGate int, enableCreditBased boolean) in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Rename Parameter taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, initialBackoff int, maxBackoff int, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Rename Parameter taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method package PartitionRequestServerHandler(partitionProvider ResultPartitionProvider, taskEventPublisher TaskEventPublisher, outboundQueue PartitionRequestQueue, creditBasedEnabled boolean) in class org.apache.flink.runtime.io.network.netty.PartitionRequestServerHandler |
From |
To |
|
Rename Parameter taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Rename Parameter taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public start(partitionProvider ResultPartitionProvider, taskEventPublisher TaskEventPublisher) : void in class org.apache.flink.runtime.io.network.netty.NettyConnectionManager |
From |
To |
|
Rename Parameter taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method public UnknownInputChannel(gate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, connectionManager ConnectionManager, initialBackoff int, maxBackoff int, metrics TaskIOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel |
From |
To |
|
Rename Parameter taskEventDispatcher : TaskEventDispatcher to taskEventPublisher : TaskEventPublisher in method package NettyProtocol(partitionProvider ResultPartitionProvider, taskEventPublisher TaskEventPublisher, creditBasedEnabled boolean) in class org.apache.flink.runtime.io.network.netty.NettyProtocol |
From |
To |