8d281f8b2b3d170385f38e8f88ec1df09d0d0efe
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public getNextNonBlocked() : BufferOrEvent renamed to public pollNext() : Optional<BufferOrEvent> in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Rename Method public getNextNonBlocked() : BufferOrEvent renamed to public pollNext() : Optional<BufferOrEvent> in class org.apache.flink.streaming.runtime.io.BarrierTracker | From | To | |
| Change Return Type | 2 | ||
| Change Return Type BufferOrEvent to Optional<BufferOrEvent> in method public pollNext() : Optional<BufferOrEvent> in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Change Return Type BufferOrEvent to Optional<BufferOrEvent> in method public pollNext() : Optional<BufferOrEvent> in class org.apache.flink.streaming.runtime.io.BarrierTracker | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type bufferOrEvent : BufferOrEvent to bufferOrEvent : Optional<BufferOrEvent> in method public processInput() : boolean in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Variable Type bufferOrEvent : BufferOrEvent to bufferOrEvent : Optional<BufferOrEvent> in method public processInput() : boolean in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Extract Method | 4 | ||
| Extract Method public isFinished() : boolean extracted from public getNextNonBlocked() : BufferOrEvent in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Extract Method private handleEmptyBuffer() : Optional<BufferOrEvent> extracted from public getNextNonBlocked() : BufferOrEvent in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Extract Method private processBufferOrEvent(bufferOrEvent BufferOrEvent) : void extracted from public processInput() : boolean in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Extract Method private processBufferOrEvent(bufferOrEvent BufferOrEvent) : void extracted from public processInput() : boolean in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To |