|
Rename Method public writeBuffer(buffer Buffer, targetChannel int) : void renamed to public addBufferConsumer(buffer BufferConsumer, targetChannel int) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest.CollectingPartitionWriter |
From |
To |
|
Rename Method package abstract addBuffer(buffer Buffer) : void renamed to package abstract addBufferConsumer(bufferConsumer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest.Source |
From |
To |
|
Rename Method public getNextBufferOrEvent() : BufferOrEvent renamed to public getNextBufferConsumer() : BufferConsumerAndChannel in class org.apache.flink.runtime.io.network.util.TestProducerSource |
From |
To |
|
Rename Method package addBuffer(buffer Buffer) : void renamed to package addBufferConsumer(bufferConsumer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest.PipelinedSubpartitionSource |
From |
To |
|
Rename Method public writeBuffer(buffer Buffer, subpartitionIndex int) : void renamed to public addBufferConsumer(bufferConsumer BufferConsumer, subpartitionIndex int) : void in class org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter |
From |
To |
|
Rename Method public writeBuffer(buffer Buffer, subpartitionIndex int) : void renamed to public addBufferConsumer(bufferConsumer BufferConsumer, subpartitionIndex int) : void in class org.apache.flink.runtime.io.network.partition.ResultPartition |
From |
To |
|
Rename Method public getNextBufferOrEvent() : BufferOrEvent renamed to public getNextBufferConsumer() : BufferConsumerAndChannel in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannelTest.TestPartitionProducerBufferSource |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method public add(bufferConsumer BufferConsumer) : boolean in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method public add(bufferConsumer BufferConsumer) : boolean in class org.apache.flink.runtime.io.network.partition.SpillableSubpartition |
From |
To |
|
Change Parameter Type queues : Queue<Buffer>[] to queues : Queue<BufferConsumer>[] in method private CollectingPartitionWriter(queues Queue<BufferConsumer>[], bufferProvider BufferProvider) in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest.CollectingPartitionWriter |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method private add(bufferConsumer BufferConsumer, finish boolean) : boolean in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Change Parameter Type buffer : Buffer to buffer : BufferConsumer in method public addBufferConsumer(buffer BufferConsumer, targetChannel int) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest.CollectingPartitionWriter |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method public abstract add(bufferConsumer BufferConsumer) : boolean in class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Change Parameter Type buffer : Buffer to buffer : BufferConsumer in method private fillRandom(partitions PipelinedSubpartition[], numPerPartition int, buffer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.InputGateFairnessTest |
From |
To |
|
Change Parameter Type buffer : Buffer to isBuffer : boolean in method protected decreaseBuffersInBacklogUnsafe(isBuffer boolean) : int in class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method private parseBuffer(bufferConsumer BufferConsumer, targetChannel int) : BufferOrEvent in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method package addBufferConsumer(bufferConsumer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest.PipelinedSubpartitionSource |
From |
To |
|
Change Parameter Type buffer : Buffer to buffer : BufferConsumer in method protected increaseBuffersInBacklog(buffer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Change Parameter Type buffers : ArrayDeque<Buffer> to buffers : ArrayDeque<BufferConsumer> in method package SpillableSubpartitionView(parent SpillableSubpartition, buffers ArrayDeque<BufferConsumer>, ioManager IOManager, memorySegmentSize int, listener BufferAvailabilityListener) in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionView |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method public addBufferConsumer(bufferConsumer BufferConsumer, subpartitionIndex int) : void in class org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method package abstract addBufferConsumer(bufferConsumer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest.Source |
From |
To |
|
Change Parameter Type buffer : Buffer to bufferConsumer : BufferConsumer in method public addBufferConsumer(bufferConsumer BufferConsumer, subpartitionIndex int) : void in class org.apache.flink.runtime.io.network.partition.ResultPartition |
From |
To |
|
Rename Variable buffer : Buffer to bufferConsumer : BufferConsumer in method protected testAddOnReleasedPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest |
From |
To |
|
Rename Variable buffer : Buffer to bufferConsumer : BufferConsumer in method private verifyViewReleasedAfterParentRelease(partition ResultSubpartition) : void in class org.apache.flink.runtime.io.network.partition.SubpartitionTestBase |
From |
To |
|
Rename Variable bufferOrEvent : BufferOrEvent to consumerAndChannel : BufferConsumerAndChannel in method public call() : Boolean in class org.apache.flink.runtime.io.network.util.TestSubpartitionProducer |
From |
To |
|
Rename Variable buffer : Buffer to bufferConsumer : BufferConsumer in method protected testAddOnFinishedPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest |
From |
To |
|
Rename Variable buffer : Buffer to bufferBuilder : BufferBuilder in method public invoke() : void in class org.apache.flink.runtime.io.network.partition.PartialConsumePipelinedResultTest.SlowBufferSender |
From |
To |
|
Rename Variable bufferOrEvent : BufferOrEvent to consumerAndChannel : BufferConsumerAndChannel in method public call() : Boolean in class org.apache.flink.runtime.io.network.util.TestPartitionProducer |
From |
To |
|
Rename Variable buffer : Buffer to bufferConsumer : BufferConsumer in method protected testAddOnPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest |
From |
To |
|
Rename Variable buffer : Buffer to bufferConsumer : BufferConsumer in method public testAddAfterFinish() : void in class org.apache.flink.runtime.io.network.partition.SubpartitionTestBase |
From |
To |
|
Rename Variable buffer : Buffer to bufferConsumer : BufferConsumer in method public testAddAfterRelease() : void in class org.apache.flink.runtime.io.network.partition.SubpartitionTestBase |
From |
To |
|
Change Variable Type queues : ArrayDeque<Buffer>[] to queues : ArrayDeque<BufferConsumer>[] in method public testBroadcastEmitBufferIndependence() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Change Variable Type queues : Queue<Buffer>[] to queues : Queue<BufferConsumer>[] in method public testBroadcastEventMixedRecords() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Change Variable Type buffer : Buffer to bufferConsumer : BufferConsumer in method protected testAddOnPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest |
From |
To |
|
Change Variable Type buffer : Buffer to bufferConsumer : BufferConsumer in method public testAddAfterFinish() : void in class org.apache.flink.runtime.io.network.partition.SubpartitionTestBase |
From |
To |
|
Change Variable Type buffer : Buffer to bufferConsumer : BufferConsumer in method public testAddAfterRelease() : void in class org.apache.flink.runtime.io.network.partition.SubpartitionTestBase |
From |
To |
|
Change Variable Type queues : Queue<Buffer>[] to queues : Queue<BufferConsumer>[] in method public testBroadcastEventNoRecords() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Change Variable Type buffer : Buffer to buffer : BufferConsumer in method public release() : void in class org.apache.flink.runtime.io.network.partition.SpillableSubpartition |
From |
To |
|
Change Variable Type buffer : Buffer to bufferConsumer : BufferConsumer in method private verifyViewReleasedAfterParentRelease(partition ResultSubpartition) : void in class org.apache.flink.runtime.io.network.partition.SubpartitionTestBase |
From |
To |
|
Change Variable Type bufferOrEvent : BufferOrEvent to consumerAndChannel : BufferConsumerAndChannel in method public call() : Boolean in class org.apache.flink.runtime.io.network.util.TestPartitionProducer |
From |
To |
|
Change Variable Type buffer : Buffer to bufferConsumer : BufferConsumer in method protected testAddOnReleasedPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest |
From |
To |
|
Change Variable Type queues : ArrayDeque<Buffer>[] to queues : ArrayDeque<BufferConsumer>[] in method public testBroadcastEventBufferReferenceCounting() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Change Variable Type bufferOrEvent : BufferOrEvent to consumerAndChannel : BufferConsumerAndChannel in method public call() : Boolean in class org.apache.flink.runtime.io.network.util.TestSubpartitionProducer |
From |
To |
|
Change Variable Type queues : ArrayDeque<Buffer>[] to queues : ArrayDeque<BufferConsumer>[] in method public testBroadcastEventBufferIndependence() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Change Variable Type buffer : Buffer to bufferConsumer : BufferConsumer in method protected testAddOnFinishedPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest |
From |
To |
|
Change Variable Type buffer : Buffer to bufferBuilder : BufferBuilder in method public invoke() : void in class org.apache.flink.runtime.io.network.partition.PartialConsumePipelinedResultTest.SlowBufferSender |
From |
To |
|
Extract And Move Method public isRecycled() : boolean extracted from protected testAddOnFinishedPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest & moved to class org.apache.flink.runtime.io.network.buffer.BufferConsumer |
From |
To |
|
Extract And Move Method public isBuffer() : boolean extracted from public testConsumeSpillablePartitionSpilledDuringConsume() : void in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionTest & moved to class org.apache.flink.runtime.io.network.buffer.BufferConsumer |
From |
To |
|
Extract And Move Method public isBuffer() : boolean extracted from public testConsumeSpilledPartition() : void in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionTest & moved to class org.apache.flink.runtime.io.network.buffer.BufferConsumer |
From |
To |
|
Extract And Move Method public isRecycled() : boolean extracted from protected testAddOnPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest & moved to class org.apache.flink.runtime.io.network.buffer.BufferConsumer |
From |
To |
|
Extract And Move Method public isRecycled() : boolean extracted from protected testAddOnReleasedPartition(pipelined ResultPartitionType) : void in class org.apache.flink.runtime.io.network.partition.ResultPartitionTest & moved to class org.apache.flink.runtime.io.network.buffer.BufferConsumer |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method private parseBuffer(bufferConsumer BufferConsumer, targetChannel int) : BufferOrEvent in class org.apache.flink.runtime.io.network.api.writer.RecordWriterTest |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method package addBufferConsumer(bufferConsumer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest.PipelinedSubpartitionSource |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method public add(bufferConsumer BufferConsumer) : boolean in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method public add(bufferConsumer BufferConsumer) : boolean in class org.apache.flink.runtime.io.network.partition.SpillableSubpartition |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method public abstract add(bufferConsumer BufferConsumer) : boolean in class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method private add(bufferConsumer BufferConsumer, finish boolean) : boolean in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method public addBufferConsumer(bufferConsumer BufferConsumer, subpartitionIndex int) : void in class org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method package abstract addBufferConsumer(bufferConsumer BufferConsumer) : void in class org.apache.flink.runtime.io.network.partition.InputGateConcurrentTest.Source |
From |
To |
|
Rename Parameter buffer : Buffer to bufferConsumer : BufferConsumer in method public addBufferConsumer(bufferConsumer BufferConsumer, subpartitionIndex int) : void in class org.apache.flink.runtime.io.network.partition.ResultPartition |
From |
To |
|
Rename Parameter buffer : Buffer to isBuffer : boolean in method protected decreaseBuffersInBacklogUnsafe(isBuffer boolean) : int in class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |