95fece85d086c9a911fd5467ef1091308348cecb
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Attribute | 3 | ||
| Rename Attribute reader1 : MutableRecordReader<T1> to bufferReader1 : BufferReaderBase in class org.apache.flink.streaming.io.CoRecordReader | From | To | |
| Rename Attribute reader2 : MutableRecordReader<T2> to bufferReader2 : BufferReaderBase in class org.apache.flink.streaming.io.CoRecordReader | From | To | |
| Rename Attribute endOfSuperstepReader1 : boolean to hasRequestedPartitions : boolean in class org.apache.flink.streaming.io.CoRecordReader | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type reader1 : MutableRecordReader<T1> to bufferReader1 : BufferReaderBase in class org.apache.flink.streaming.io.CoRecordReader | From | To | |
| Change Attribute Type reader2 : MutableRecordReader<T2> to bufferReader2 : BufferReaderBase in class org.apache.flink.streaming.io.CoRecordReader | From | To | |
| Extract Method | 1 | ||
| Extract Method public requestPartitionsOnce() : void extracted from protected getNextRecord(target1 T1, target2 T2) : int in class org.apache.flink.streaming.io.CoRecordReader | From | To |