|
Rename Variable numChannels : int to numberOfChannels : int in method public testMixedSequence() : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testConsumptionWithMixedChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testSpillWhileReading() : void in class org.apache.flink.streaming.runtime.io.BufferBlockerTestBase |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testForward() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testFairConsumptionLocalChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateFairnessTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testConsumptionWithLocalChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testBroadcastEventNoRecords() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testBroadcastEventMixedRecords() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method private emitRecordWithBroadcastPartitionerOrBroadcastEmitRecord(isBroadcastEmit boolean) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testFairConsumptionRemoteChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateFairnessTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testFairConsumptionLocalChannelsPreFilled() : void in class org.apache.flink.runtime.io.network.partition.InputGateFairnessTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testConsumptionWithRemoteChannels() : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testFairConsumptionRemoteChannelsPreFilled() : void in class org.apache.flink.runtime.io.network.partition.InputGateFairnessTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testSpillAndRollOverSimple() : void in class org.apache.flink.streaming.runtime.io.BufferBlockerTestBase |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testBufferSequence() : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testMultipleSequences() : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testForcedRebalance() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable numChannels : int to numberOfChannels : int in method public testEventSequence() : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private SequenceToConsume(bufferRnd Random, events ArrayList<BufferOrEvent>, sequence BufferOrEventSequence, numBuffersAndEvents int, numberOfChannels int) in class org.apache.flink.streaming.runtime.io.BufferBlockerTestBase.SequenceToConsume |
From |
To |
|
Rename Parameter numberOfOutputChannels : int to numberOfChannels : int in method public selectChannels(record T, numberOfChannels int) : int[] in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest.Broadcast |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numberOfChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Parameter numberOfOutputChannels : int to numberOfChannels : int in method public selectChannels(record SerializationDelegate<StreamRecord<T>>, numberOfChannels int) : int[] in class org.apache.flink.streaming.runtime.partitioner.CustomPartitionerWrapper |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private verifyBroadcastSelectedChannels(numRecords int, numberOfChannels int, recordType Enum) : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method public MockInputGate(pageSize int, numberOfChannels int, bufferOrEvents List<BufferOrEvent>) in class org.apache.flink.streaming.runtime.io.MockInputGate |
From |
To |
|
Rename Parameter numberOfOutputChannels : int to numberOfChannels : int in method public selectChannels(record SerializationDelegate<StreamRecord<T>>, numberOfChannels int) : int[] in class org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner |
From |
To |
|
Rename Parameter numberOfOutputChannels : int to numberOfChannels : int in method public selectChannels(record T, numberOfChannels int) : int[] in class org.apache.flink.runtime.io.network.api.writer.RoundRobinChannelSelector |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private verifyForwardSelectedChannels(numRecords int, numberOfChannels int, recordType Enum) : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Parameter numberOfOutputChannels : int to numberOfChannels : int in method public selectChannels(record SerializationDelegate<StreamRecord<T>>, numberOfChannels int) : int[] in class org.apache.flink.streaming.runtime.partitioner.RescalePartitioner |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private verifyPartitionHashSelectedChannels(numRecords int, numberOfChannels int, recordType Enum) : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private generateRandomEvent(rnd Random, numberOfChannels int) : BufferOrEvent in class org.apache.flink.streaming.runtime.io.BufferBlockerTestBase |
From |
To |
|
Rename Parameter numberOfOutputChannels : int to numberOfChannels : int in method public selectChannels(record SerializationDelegate<StreamRecord<T>>, numberOfChannels int) : int[] in class org.apache.flink.streaming.runtime.partitioner.ShufflePartitioner |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method public MockInputGate(pageSize int, numberOfChannels int, bufferOrEvents List<BufferOrEvent>, owningTaskName String) in class org.apache.flink.streaming.runtime.io.MockInputGate |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private generateAndWriteEvent(fileChannel FileChannel, rnd Random, numberOfChannels int) : BufferOrEvent in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method public selectChannels(record T, numberOfChannels int) : int[] in class org.apache.flink.runtime.io.network.api.writer.ChannelSelector |
From |
To |
|
Rename Parameter numberOfOutputChannels : int to numberOfChannels : int in method public selectChannels(record SerializationDelegate<StreamRecord<T>>, numberOfChannels int) : int[] in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method public selectChannels(record SerializationDelegate<StreamRecord<T>>, numberOfChannels int) : int[] in class org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner |
From |
To |
|
Rename Parameter numChannels : int to numberOfChannels : int in method private getSelectedChannelsHitCount(shipStrategyType ShipStrategyType, numRecords int, numberOfChannels int, recordType Enum) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |