|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testRetriggerPartitionRequest() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testDoublePartitionRequest() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testAvailableBuffersLessThanRequiredBuffers() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testConcurrentOnSenderBacklogAndRelease() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testAvailableBuffersMoreThanRequiredBuffers() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testConcurrentOnSenderBacklogAndRecycle() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testAvailableBuffersEqualToRequiredBuffers() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testFairDistributionFloatingBuffers() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testReceiveBuffer() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testNotifyCreditAvailable() : void in class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandlerTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testConcurrentRecycleAndRelease2() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testNotifyCreditAvailableAfterReleased() : void in class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandlerTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testConcurrentRecycleAndRelease() : 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 createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testReceiveBuffer() : void in class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandlerTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testThrowExceptionForNoAvailableBuffer() : void in class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandlerTest & moved to class org.apache.flink.runtime.io.network.partition.InputChannelTestUtils |
From |
To |
|
Extract And Move Method public createSingleInputGate(numberOfChannels int) : SingleInputGate extracted from public testFailureInNotifyBufferAvailable() : 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 |