d3ac0adfd7ed8878f0c80e0c454c580969e40cfc
Files Diff
- Added: 0
- Removed: 3
- Renamed: 0
- Modified: 34
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public read() : IteratorWrappingTestSingleInputGate<T> renamed to public notifyNonEmpty() : IteratorWrappingTestSingleInputGate<T> in class org.apache.flink.runtime.io.network.partition.consumer.IteratorWrappingTestSingleInputGate | From | To | |
| Move Method | 2 | ||
| Move Method public testConsumeWithFewBuffers() : void from class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewSyncIOTest to public testConsumeWithFewBuffers() : void from class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewTest | From | To | |
| Move Method public testWriteConsume() : void from class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewSyncIOTest to public testWriteConsume() : void from class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewTest | From | To | |
| Rename Variable | 4 | ||
| Rename Variable view : ResultSubpartitionView to consumer : TestSubpartitionConsumer in method public testReadMultipleFilesWithSingleBufferPool() : void in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewTest | From | To | |
| Rename Variable producer : Future<Boolean> to producerResult : Future<Boolean> in method private testProduceConsume(isSlowProducer boolean, isSlowConsumer boolean) : void in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartitionTest | From | To | |
| Rename Variable readers : ResultSubpartitionView[] to consumers : TestSubpartitionConsumer[] in method public testReadMultipleFilesWithSingleBufferPool() : void in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewTest | From | To | |
| Rename Variable consumerBlocked : boolean to consumerWaiting : boolean in method public testCancelAsyncProducerAndConsumer() : void in class org.apache.flink.runtime.taskmanager.TaskCancelAsyncProducerConsumerITCase | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Buffer to BufferAndAvailability in method package getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.partition.consumer.InputChannelTest.MockInputChannel | From | To | |
| Change Variable Type | 6 | ||
| Change Variable Type readers : ResultSubpartitionView[] to consumers : TestSubpartitionConsumer[] in method public testReadMultipleFilesWithSingleBufferPool() : void in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewTest | From | To | |
| Change Variable Type consumer : Future<Boolean> to consumer : TestSubpartitionConsumer in method private testProduceConsume(isSlowProducer boolean, isSlowConsumer boolean) : void in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartitionTest | From | To | |
| Change Variable Type answer : Answer<Buffer> to answer : Answer<BufferAndAvailability> in method private setupInputChannels() : void in class org.apache.flink.runtime.io.network.partition.consumer.StreamTestSingleInputGate | From | To | |
| Change Variable Type serverAndClient : NettyServerAndClient to serverAndClient : NettyTestUtil.NettyServerAndClient in method public testRemoteClose() : void in class org.apache.flink.runtime.io.network.netty.ServerTransportErrorHandlingTest | From | To | |
| Change Variable Type view : ResultSubpartitionView to consumer : TestSubpartitionConsumer in method public testReadMultipleFilesWithSingleBufferPool() : void in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewTest | From | To | |
| Change Variable Type notifications : BlockingQueue<InputChannel> to notifications : ArrayDeque<InputChannel> in method public TestSingleInputGate(numberOfInputChannels int, initialize boolean) in class org.apache.flink.runtime.io.network.partition.consumer.TestSingleInputGate | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type stubbing : OngoingStubbing<Buffer> to stubbing : OngoingStubbing<InputChannel.BufferAndAvailability> in class org.apache.flink.runtime.io.network.partition.consumer.TestInputChannel | From | To |