650c528fc4452e6b11294062699001a5b4a21ac9
Files Diff
- Added: 4
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Variable Type | 1 | ||
| Change Variable Type nextNonprocessed : BufferOrEvent to nextNonprocessed : SpillingBufferOrEvent in method protected getNonProcessed() : BufferOrEvent in class org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type nonprocessed : Queue<BufferOrEvent> to nonprocessed : Queue<SpillingBufferOrEvent> in class org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Change Attribute Type blockedNonprocessed : Queue<BufferOrEvent> to blockedNonprocessed : Queue<SpillingBufferOrEvent> in class org.apache.flink.streaming.io.BarrierBuffer | From | To |