a3838255e3df08911b18311df58a59cb0c84c4d8
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 4 | ||
| Rename Method package abstract createBarrierHandler(gate InputGate) : BarrierBuffer renamed to package abstract createBarrierBuffer(gate InputGate) : BarrierBuffer in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Rename Method public checkNoTempFilesRemain() : void renamed to public ensureEmpty() : void in class org.apache.flink.streaming.runtime.io.SpillingBarrierBufferTest | From | To | |
| Rename Method public createBarrierHandler(gate InputGate) : BarrierBuffer renamed to public createBarrierBuffer(gate InputGate) : BarrierBuffer in class org.apache.flink.streaming.runtime.io.SpillingBarrierBufferTest | From | To | |
| Rename Method public createBarrierHandler(gate InputGate) : BarrierBuffer renamed to public createBarrierBuffer(gate InputGate) : BarrierBuffer in class org.apache.flink.streaming.runtime.io.CreditBasedBarrierBufferTest | From | To | |
| Extract Method | 17 | ||
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testEndOfStreamWhileCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testStartAlignmentWithClosedChannels() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testSingleChannelAbortCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelAbortCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelSkippingCheckpointsViaBlockedInputs() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelTrailingBlockedData() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelWithQueuedFutureBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelWithBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testAbortViaQueuedBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelNoBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testSingleChannelNoBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testSingleChannelWithBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testAbortWhileHavingQueuedBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelJumpingOverCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testIgnoreCancelBarrierIfCheckpointSubsumed() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testMultiChannelSkippingCheckpoints() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To | |
| Extract Method protected createBarrierBuffer(numberOfChannels int, sequence BufferOrEvent[]) : BarrierBuffer extracted from public testEarlyCleanup() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTestBase | From | To |