9311b9a9da57796e1eb91aa0ec5fa8948b732a47
Files Diff
- Added: 4
- Removed: 4
- Renamed: 0
- Modified: 12
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getSpillFile() : File renamed to package getCurrentSpillFile() : File in class org.apache.flink.streaming.runtime.io.BufferSpiller | From | To | |
| Extract Attribute | 1 | ||
| Extract Attribute private PAGE_SIZE : int in class org.apache.flink.streaming.runtime.io.BarrierBufferMassiveRandomTest | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute nonProcessed : ArrayDeque<SpillingBufferOrEvent> to queuedBuffered : ArrayDeque<BufferSpiller.SpilledBufferOrEventSequence> in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Rename Attribute spillingChannel : FileChannel to currentChannel : FileChannel in class org.apache.flink.streaming.runtime.io.BufferSpiller | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type nonProcessed : ArrayDeque<SpillingBufferOrEvent> to queuedBuffered : ArrayDeque<BufferSpiller.SpilledBufferOrEventSequence> in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To |