|
Move Method protected createResultPartition(jobId JobID, partitionId ResultPartitionID, environment NetworkEnvironment, channels int) : ResultPartitionWriter from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected createResultPartition(jobId JobID, partitionId ResultPartitionID, environment NetworkEnvironment, channels int) : ResultPartitionWriter from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Method private generatePartitionIds() : void from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to private generatePartitionIds() : void from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Method public tearDown() : void from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to public tearDown() : void from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Method public setUp(writers int, channels int) : void from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to public setUp(writers int, channels int) : void from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Method public createReceiver() : SerializingLongReceiver from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to public createReceiver() : SerializingLongReceiver from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Method private createNettyNetworkEnvironment(bufferPoolSize int) : NetworkEnvironment from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to private createNettyNetworkEnvironment(bufferPoolSize int) : NetworkEnvironment from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Method private createInputGate(jobId JobID, dataSetID IntermediateDataSetID, executionAttemptID ExecutionAttemptID, senderLocation TaskManagerLocation, environment NetworkEnvironment, channels int) : InputGate from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to private createInputGate(jobId JobID, dataSetID IntermediateDataSetID, executionAttemptID ExecutionAttemptID, senderLocation TaskManagerLocation, environment NetworkEnvironment, channels int) : InputGate from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected receiverEnv : NetworkEnvironment from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected receiverEnv : NetworkEnvironment from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected dataSetID : IntermediateDataSetID from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected dataSetID : IntermediateDataSetID from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected ioManager : IOManager from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected ioManager : IOManager from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute private LOCAL_ADDRESS : InetAddress from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to private LOCAL_ADDRESS : InetAddress from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected senderEnv : NetworkEnvironment from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected senderEnv : NetworkEnvironment from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute private BUFFER_SIZE : int from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to private BUFFER_SIZE : int from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected executionAttemptID : ExecutionAttemptID from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected executionAttemptID : ExecutionAttemptID from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected jobId : JobID from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected jobId : JobID from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected partitionIds : ResultPartitionID[] from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected partitionIds : ResultPartitionID[] from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute private NUM_SLOTS_AND_THREADS : int from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to private NUM_SLOTS_AND_THREADS : int from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |
|
Move Attribute protected channels : int from class org.apache.flink.runtime.io.network.benchmark.NetworkBenchmarkEnvironment to protected channels : int from class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment |
From |
To |