|
Rename Method public setupBufferPoolFactoryFromNetworkEnvironment(environment NetworkEnvironment) : ResultPartitionBuilder renamed to public setupBufferPoolFactoryFromNettyShuffleEnvironment(environment NettyShuffleEnvironment) : ResultPartitionBuilder in class org.apache.flink.runtime.io.network.partition.ResultPartitionBuilder |
From |
To |
|
Rename Method package setupFromNetworkEnvironment(network NetworkEnvironment) : InputChannelBuilder renamed to package setupFromNettyShuffleEnvironment(network NettyShuffleEnvironment) : InputChannelBuilder in class org.apache.flink.runtime.io.network.partition.consumer.InputChannelBuilder |
From |
To |
|
Rename Method private createNetworkEnvironment() : NetworkEnvironment renamed to private createNettyShuffleEnvironment() : NettyShuffleEnvironment in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Rename Method public testInputGateRemovalFromNetworkEnvironment() : void renamed to public testInputGateRemovalFromNettyShuffleEnvironment() : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Rename Method private createNettyNetworkEnvironment(bufferPoolSize int, config Configuration) : NetworkEnvironment renamed to private createShuffleEnvironment(bufferPoolSize int, config Configuration) : NettyShuffleEnvironment in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Change Parameter Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method private createInputGateWithLocalChannels(network NettyShuffleEnvironment, numberOfGates int, numberOfLocalChannels int) : Map<InputGateID,SingleInputGate> in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Parameter Type environment : NetworkEnvironment to environment : NettyShuffleEnvironment in method public setupBufferPoolFactory(environment NettyShuffleEnvironment) : SingleInputGateBuilder in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateBuilder |
From |
To |
|
Change Parameter Type environment : NetworkEnvironment to environment : NettyShuffleEnvironment in method public createPartition(environment NettyShuffleEnvironment, partitionType ResultPartitionType, numChannels int) : ResultPartition in class org.apache.flink.runtime.io.network.partition.PartitionTestUtils |
From |
To |
|
Change Parameter Type config : NetworkEnvironmentConfiguration to config : NettyShuffleEnvironmentConfiguration in method private NettyShuffleEnvironment(taskExecutorLocation ResourceID, config NettyShuffleEnvironmentConfiguration, networkBufferPool NetworkBufferPool, connectionManager ConnectionManager, resultPartitionManager ResultPartitionManager, resultPartitionFactory ResultPartitionFactory, singleInputGateFactory SingleInputGateFactory) in class org.apache.flink.runtime.io.network.NettyShuffleEnvironment |
From |
To |
|
Change Parameter Type environment : NetworkEnvironment to environment : NettyShuffleEnvironment in method protected createInputGate(environment NettyShuffleEnvironment, numberOfInputChannels int, partitionType ResultPartitionType) : SingleInputGate in class org.apache.flink.runtime.io.network.partition.consumer.InputGateTestBase |
From |
To |
|
Change Parameter Type config : NetworkEnvironmentConfiguration to config : NettyShuffleEnvironmentConfiguration in method public create(config NettyShuffleEnvironmentConfiguration, taskExecutorLocation ResourceID, taskEventPublisher TaskEventPublisher, metricGroup MetricGroup, ioManager IOManager) : NettyShuffleEnvironment in class org.apache.flink.runtime.io.network.NettyShuffleEnvironment |
From |
To |
|
Change Parameter Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method private createSingleInputGate(network NettyShuffleEnvironment, partitionType ResultPartitionType, numberOfChannels int) : SingleInputGate in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentTest |
From |
To |
|
Change Parameter Type environment : NetworkEnvironment to environment : NettyShuffleEnvironment in method protected createResultPartition(jobId JobID, partitionId ResultPartitionID, environment NettyShuffleEnvironment, channels int) : ResultPartitionWriter in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Change Parameter Type networkConfig : NetworkEnvironmentConfiguration to networkConfig : NettyShuffleEnvironmentConfiguration in method public SingleInputGateFactory(taskExecutorLocation ResourceID, networkConfig NettyShuffleEnvironmentConfiguration, connectionManager ConnectionManager, partitionManager ResultPartitionManager, taskEventPublisher TaskEventPublisher, networkBufferPool NetworkBufferPool) in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateFactory |
From |
To |
|
Change Parameter Type environment : NetworkEnvironment to environment : NettyShuffleEnvironment in method public setupBufferPoolFactoryFromNettyShuffleEnvironment(environment NettyShuffleEnvironment) : ResultPartitionBuilder in class org.apache.flink.runtime.io.network.partition.ResultPartitionBuilder |
From |
To |
|
Change Parameter Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method package setupFromNettyShuffleEnvironment(network NettyShuffleEnvironment) : InputChannelBuilder in class org.apache.flink.runtime.io.network.partition.consumer.InputChannelBuilder |
From |
To |
|
Change Parameter Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method private addUnknownInputChannel(network NettyShuffleEnvironment, inputGate SingleInputGate, partitionId ResultPartitionID, channelIndex int) : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Return Type NetworkEnvironmentConfiguration to NettyShuffleEnvironmentConfiguration in method public getConfiguration() : NettyShuffleEnvironmentConfiguration in class org.apache.flink.runtime.io.network.NettyShuffleEnvironment |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setPartitionRequestInitialBackoff(partitionRequestInitialBackoff int) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironment to NettyShuffleEnvironment in method public create(config NettyShuffleEnvironmentConfiguration, taskExecutorLocation ResourceID, taskEventPublisher TaskEventPublisher, metricGroup MetricGroup, ioManager IOManager) : NettyShuffleEnvironment in class org.apache.flink.runtime.io.network.NettyShuffleEnvironment |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setNumNetworkBuffers(numNetworkBuffers int) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setNettyConfig(nettyConfig NettyConfig) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setTaskManagerLocation(taskManagerLocation ResourceID) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setIsCreditBased(isCreditBased boolean) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironment to NettyShuffleEnvironment in method public fromShuffleContext(shuffleEnvironmentContext ShuffleEnvironmentContext) : NettyShuffleEnvironment in class org.apache.flink.runtime.io.network.NettyShuffleEnvironment |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setNetworkBuffersPerChannel(networkBuffersPerChannel int) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setMetricGroup(metricGroup MetricGroup) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironment to NettyShuffleEnvironment in method public build() : NettyShuffleEnvironment in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironment to NettyShuffleEnvironment in method private createShuffleEnvironment(bufferPoolSize int, config Configuration) : NettyShuffleEnvironment in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setIOManager(ioManager IOManager) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironmentConfiguration to NettyShuffleEnvironmentConfiguration in method public fromConfiguration(configuration Configuration, maxJvmHeapMemory long, localTaskManagerCommunication boolean, taskManagerAddress InetAddress) : NettyShuffleEnvironmentConfiguration in class org.apache.flink.runtime.taskmanager.NettyShuffleEnvironmentConfiguration |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setTaskEventDispatcher(taskEventDispatcher TaskEventDispatcher) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironment to NettyShuffleEnvironment in method private createNettyShuffleEnvironment() : NettyShuffleEnvironment in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setNetworkBufferSize(networkBufferSize int) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setFloatingNetworkBuffersPerGate(floatingNetworkBuffersPerGate int) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Change Return Type NetworkEnvironmentBuilder to NettyShuffleEnvironmentBuilder in method public setPartitionRequestMaxBackoff(partitionRequestMaxBackoff int) : NettyShuffleEnvironmentBuilder in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Rename Class org.apache.flink.runtime.io.network.NetworkEnvironment renamed to org.apache.flink.runtime.io.network.NettyShuffleEnvironment |
From |
To |
|
Rename Class org.apache.flink.runtime.taskexecutor.NetworkEnvironmentConfigurationTest renamed to org.apache.flink.runtime.taskexecutor.NettyShuffleEnvironmentConfigurationTest |
From |
To |
|
Rename Class org.apache.flink.runtime.io.network.NetworkEnvironmentBuilder renamed to org.apache.flink.runtime.io.network.NettyShuffleEnvironmentBuilder |
From |
To |
|
Rename Class org.apache.flink.configuration.NetworkEnvironmentOptions renamed to org.apache.flink.configuration.NettyShuffleEnvironmentOptions |
From |
To |
|
Rename Class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration renamed to org.apache.flink.runtime.taskmanager.NettyShuffleEnvironmentConfiguration |
From |
To |
|
Rename Class org.apache.flink.runtime.io.network.NetworkEnvironmentTest renamed to org.apache.flink.runtime.io.network.NettyShuffleEnvironmentTest |
From |
To |
|
Change Variable Type config : NetworkEnvironmentConfiguration to config : NettyShuffleEnvironmentConfiguration in method public setupBufferPoolFactory(environment NettyShuffleEnvironment) : SingleInputGateBuilder in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateBuilder |
From |
To |
|
Change Variable Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method public testRegisterTaskUsesBoundedBuffers() : void in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentTest |
From |
To |
|
Change Variable Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method private testReleaseMemory(resultPartitionType ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest |
From |
To |
|
Change Variable Type netEnv : NetworkEnvironment to netEnv : NettyShuffleEnvironment in method public testRequestBackoffConfiguration() : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Variable Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method public testUpdateUnknownInputChannel() : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Variable Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method public testInputGateRemovalFromNettyShuffleEnvironment() : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Variable Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method private testRegisterTaskWithLimitedBuffers(bufferPoolSize int) : void in class org.apache.flink.runtime.io.network.NettyShuffleEnvironmentTest |
From |
To |
|
Change Variable Type networkConfig : NetworkEnvironmentConfiguration to networkConfig : NettyShuffleEnvironmentConfiguration in method public testNetworkRequestBackoffAndBuffers() : void in class org.apache.flink.runtime.taskexecutor.NettyShuffleEnvironmentConfigurationTest |
From |
To |
|
Change Variable Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method public testRequestBuffersWithRemoteInputChannel() : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Variable Type network : NetworkEnvironment to network : NettyShuffleEnvironment in method public testRequestBuffersWithUnknownInputChannel() : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Change Variable Type networkConfig : NetworkEnvironmentConfiguration to networkConfig : NettyShuffleEnvironmentConfiguration in method public fromShuffleContext(shuffleEnvironmentContext ShuffleEnvironmentContext) : NettyShuffleEnvironment in class org.apache.flink.runtime.io.network.NettyShuffleEnvironment |
From |
To |
|
Change Variable Type that : NetworkEnvironmentConfiguration to that : NettyShuffleEnvironmentConfiguration in method public equals(obj Object) : boolean in class org.apache.flink.runtime.taskmanager.NettyShuffleEnvironmentConfiguration |
From |
To |