e1d1bd0a224b32f6a488e400f5f07e4ab4b65869
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.runtime.io.BarrierBufferTest.MockInputGate moved to org.apache.flink.streaming.runtime.io.MockInputGate | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute numReceivedBarriers : long to numBarriersReceived : int in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Extract Variable | 1 | ||
| Extract Variable bufferedNow : BufferSpiller.SpilledBufferOrEventSequence in method private releaseBlocks() : void from class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type numReceivedBarriers : long to numBarriersReceived : int in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Extract Method | 1 | ||
| Extract Method private completeBufferedSequence() : void extracted from public getNextNonBlocked() : BufferOrEvent in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To |