5327d56dc6f6f49a07054d89efcf30c894c85eca
Files Diff
- Added: 3
- Removed: 2
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Inline Method | 1 | ||
| Inline Method private containsNonprocessed() : boolean inlined to public getNextNonBlocked() : BufferOrEvent in class org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Move Class | 2 | ||
| Move Class org.apache.flink.runtime.io.network.api.reader.BarrierBuffer moved to org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Move Class org.apache.flink.runtime.io.network.api.reader.StreamingAbstractRecordReader moved to org.apache.flink.streaming.io.StreamingAbstractRecordReader | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute receivedSuperstep : boolean to superstepStarted : boolean in class org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Inline Variable | 2 | ||
| Inline Variable nextBufferOrEvent : BufferOrEvent in method public getNextNonBlocked() : BufferOrEvent from class org.apache.flink.runtime.io.network.api.reader.BarrierBuffer | From | To | |
| Inline Variable channelIndex : int in method public processSuperstep(bufferOrEvent BufferOrEvent) : void from class org.apache.flink.runtime.io.network.api.reader.BarrierBuffer | From | To | |
| Extract Method | 3 | ||
| Extract Method protected actOnAllBlocked() : void extracted from private blockChannel(channelIndex int) : void in class org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Extract Method protected releaseBlocks() : void extracted from private blockChannel(channelIndex int) : void in class org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Extract Method protected isAllBlocked() : boolean extracted from private blockChannel(channelIndex int) : void in class org.apache.flink.streaming.io.BarrierBuffer | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type availableRecordReaders : BlockingQueue<Integer> to availableRecordReaders : LinkedBlockingDeque<Integer> in class org.apache.flink.streaming.io.CoRecordReader | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter bufferReader1 : InputGate to inputgate1 : InputGate in method public CoRecordReader(inputgate1 InputGate, inputgate2 InputGate) in class org.apache.flink.streaming.io.CoRecordReader | From | To | |
| Rename Parameter bufferReader2 : InputGate to inputgate2 : InputGate in method public CoRecordReader(inputgate1 InputGate, inputgate2 InputGate) in class org.apache.flink.streaming.io.CoRecordReader | From | To |