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 |