|
Extract And Move Method public createLocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionManager ResultPartitionManager) : LocalInputChannel extracted from public testFairConsumptionLocalChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateFairnessTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createRemoteInputChannel(inputGate SingleInputGate, channelIndex int, connectionManager ConnectionManager) : RemoteInputChannel extracted from public testProducerFailedException() : void in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannelTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createLocalInputChannel(inputGate SingleInputGate, partitionManager ResultPartitionManager) : LocalInputChannel extracted from public testProducerFailedException() : void in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannelTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createLocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionManager ResultPartitionManager) : LocalInputChannel extracted from public testConsumptionWithMixedChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createLocalInputChannel(inputGate SingleInputGate, partitionManager ResultPartitionManager, initialBackoff int, maxBackoff int) : LocalInputChannel extracted from public testConcurrentReleaseAndRetriggerPartitionRequest() : void in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannelTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createLocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionManager ResultPartitionManager) : LocalInputChannel extracted from public testConsumptionWithLocalChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createLocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionManager ResultPartitionManager) : LocalInputChannel extracted from public testFairConsumptionLocalChannelsPreFilled() : void in class org.apache.flink.runtime.io.network.partition.InputGateFairnessTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |