|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public isFinished() : boolean in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public requestPartitionsOnce() : void in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public startNextSuperstep() : void in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method private resetRemainingReaders() : void in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public setIterativeReader() : void in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public hasReachedEndOfSuperstep() : boolean in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public sendTaskEvent(event TaskEvent) : void in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public subscribeToTaskEvent(eventListener EventListener<TaskEvent>, eventType Class<? extends TaskEvent>) : void in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Variable Type reader : BufferReader to reader : BufferReaderBase in method public UnionBufferReader(readers BufferReaderBase...) in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Attribute Type currentReader : BufferReader to currentReader : BufferReaderBase in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Attribute Type readers : BufferReader[] to readers : BufferReaderBase[] in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Attribute Type readersWithData : BlockingQueue<BufferReader> to readersWithData : BlockingQueue<BufferReaderBase> in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader.DataAvailabilityListener |
From |
To |
|
Change Attribute Type readerToIndexOffsetMap : Map<BufferReader,Integer> to readerToIndexOffsetMap : Map<BufferReaderBase,Integer> in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |
|
Change Attribute Type readerListener : AtomicReference<EventListener<BufferReader>> to readerListener : AtomicReference<EventListener<BufferReaderBase>> in class org.apache.flink.runtime.io.network.api.reader.BufferReader |
From |
To |
|
Change Attribute Type remainingReaders : Set<BufferReader> to remainingReaders : Set<BufferReaderBase> in class org.apache.flink.runtime.io.network.api.reader.UnionBufferReader |
From |
To |