4c86985dae04f0cb4daa7204f8dabc462d275041
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Method | 10 | ||
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testInterleavedCancellationBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testSingleChannelNoBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testSingleChannelWithSkippedBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testSingleChannelWithBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testSingleChannelAbortCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testMultiChannelAbortCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testCompleteCheckpointsOnLateBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testMultiChannelWithBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testMultiChannelNoBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To | |
| Extract Method private createBarrierTracker(numberOfChannels int, sequence BufferOrEvent[]) : BarrierTracker extracted from public testMultiChannelSkippingCheckpoints() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest | From | To |