261efa8f6a321a9303705c35681c0d67880213bb
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method private waitAndGetNextInputGate(blocking boolean) : Optional<InputGateWithData> renamed to private waitAndGetNextData(blocking boolean) : Optional<InputWithData<InputGate,BufferOrEvent>> in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | From | To | |
| Rename Variable | 2 | ||
| Rename Variable inputGateWithData : InputGateWithData to inputWithData : InputWithData<InputGate,BufferOrEvent> in method private getNextBufferOrEvent(blocking boolean) : Optional<BufferOrEvent> in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | From | To | |
| Rename Variable currentChannel : InputChannel to inputChannel : InputChannel in method private waitAndGetNextData(blocking boolean) : Optional<InputWithData<InputChannel,BufferAndAvailability>> in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Optional<InputGateWithData> to Optional<InputWithData<InputGate,BufferOrEvent>> in method private waitAndGetNextData(blocking boolean) : Optional<InputWithData<InputGate,BufferOrEvent>> in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type inputGateWithData : InputGateWithData to inputWithData : InputWithData<InputGate,BufferOrEvent> in method private getNextBufferOrEvent(blocking boolean) : Optional<BufferOrEvent> in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | From | To | |
| Change Variable Type next : Optional<InputGateWithData> to next : Optional<InputWithData<InputGate,BufferOrEvent>> in method private getNextBufferOrEvent(blocking boolean) : Optional<BufferOrEvent> in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | From | To | |
| Extract Method | 4 | ||
| Extract Method private handleEndOfPartitionEvent(bufferOrEvent BufferOrEvent, inputGate InputGate) : void extracted from private getNextBufferOrEvent(blocking boolean) : Optional<BufferOrEvent> in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | From | To | |
| Extract Method private transformToBufferOrEvent(buffer Buffer, moreAvailable boolean, currentChannel InputChannel) : BufferOrEvent extracted from private getNextBufferOrEvent(blocking boolean) : Optional<BufferOrEvent> in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate | From | To | |
| Extract Method private waitAndGetNextData(blocking boolean) : Optional<InputWithData<InputChannel,BufferAndAvailability>> extracted from private getNextBufferOrEvent(blocking boolean) : Optional<BufferOrEvent> in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate | From | To | |
| Extract Method private adjustForUnionInputGate(bufferOrEvent BufferOrEvent, inputGate InputGate, moreInputGatesAvailable boolean) : BufferOrEvent extracted from private getNextBufferOrEvent(blocking boolean) : Optional<BufferOrEvent> in class org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | From | To |