|
Change Parameter Type bufferReader2 : BufferReaderBase to bufferReader2 : InputGate in method public CoRecordReader(bufferReader1 InputGate, bufferReader2 InputGate) in class org.apache.flink.streaming.io.CoRecordReader |
From |
To |
|
Change Parameter Type reader : BufferReaderBase to inputGate : InputGate in method protected AbstractRecordReader(inputGate InputGate) in class org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader |
From |
To |
|
Change Parameter Type eventType : Class<? extends T> to eventType : Class<? extends TaskEvent> in method public unsubscribe(listener EventListener<TaskEvent>, eventType Class<? extends TaskEvent>) : void in class org.apache.flink.runtime.io.network.api.TaskEventHandler |
From |
To |
|
Change Parameter Type bufferReader : BufferReaderBase to bufferReader : InputGate in method public onEvent(bufferReader InputGate) : void in class org.apache.flink.streaming.io.CoRecordReader |
From |
To |
|
Change Parameter Type reader : BufferReaderBase to inputGate : InputGate in method public MutableRecordReader(inputGate InputGate) in class org.apache.flink.runtime.io.network.api.reader.MutableRecordReader |
From |
To |
|
Change Parameter Type listener : EventListener<T> to listener : EventListener<TaskEvent> in method public subscribe(listener EventListener<TaskEvent>, eventType Class<? extends TaskEvent>) : void in class org.apache.flink.runtime.io.network.api.TaskEventHandler |
From |
To |
|
Change Parameter Type event : T to event : TaskEvent in method public publish(event TaskEvent) : void in class org.apache.flink.runtime.io.network.api.TaskEventHandler |
From |
To |
|
Change Parameter Type reader : BufferReaderBase to reader : InputGate in method public IndexedMutableReader(reader InputGate) in class org.apache.flink.streaming.io.IndexedMutableReader |
From |
To |
|
Change Parameter Type bufferReader1 : BufferReaderBase to bufferReader1 : InputGate in method public CoRecordReader(bufferReader1 InputGate, bufferReader2 InputGate) in class org.apache.flink.streaming.io.CoRecordReader |
From |
To |
|
Change Parameter Type reader : BufferReaderBase to inputGate : InputGate in method public RecordReader(inputGate InputGate, recordType Class<T>) in class org.apache.flink.runtime.io.network.api.reader.RecordReader |
From |
To |
|
Change Parameter Type eventType : Class<? extends T> to eventType : Class<? extends TaskEvent> in method public subscribe(listener EventListener<TaskEvent>, eventType Class<? extends TaskEvent>) : void in class org.apache.flink.runtime.io.network.api.TaskEventHandler |
From |
To |
|
Change Parameter Type listener : EventListener<T> to listener : EventListener<TaskEvent> in method public unsubscribe(listener EventListener<TaskEvent>, eventType Class<? extends TaskEvent>) : void in class org.apache.flink.runtime.io.network.api.TaskEventHandler |
From |
To |
|
Move Method public create(runtimeEnvironment RuntimeEnvironment, networkEnvironment NetworkEnvironment, desc PartitionConsumerDeploymentDescriptor) : BufferReader from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public create(networkEnvironment NetworkEnvironment, desc PartitionConsumerDeploymentDescriptor) : SingleInputGate from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Method public updateInputChannel(partitionInfo PartitionInfo) : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public updateInputChannel(partitionInfo PartitionInfo) : void from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Method public getConsumedResultId() : IntermediateDataSetID from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public getConsumedResultId() : IntermediateDataSetID from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Method public getBufferProvider() : BufferProvider from class org.apache.flink.runtime.io.network.api.reader.BufferReader to package getBufferProvider() : BufferProvider from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Method public releaseAllResources() : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public releaseAllResources() : void from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Method public getNumberOfInputChannels() : int from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public getNumberOfInputChannels() : int from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Method public setInputChannel(partitionId IntermediateResultPartitionID, inputChannel InputChannel) : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public setInputChannel(partitionId IntermediateResultPartitionID, inputChannel InputChannel) : void from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Method public testBackwardsEventWithUninitializedChannel() : void from class org.apache.flink.runtime.io.network.api.reader.BufferReaderTest to public testBackwardsEventWithUninitializedChannel() : void from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateTest |
From |
To |
|
Move Method public setBufferPool(bufferPool BufferPool) : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public setBufferPool(bufferPool BufferPool) : void from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private numberOfUninitializedChannels : int from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private numberOfUninitializedChannels : int from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private LOG : Logger from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private LOG : Logger from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private inputChannelsWithData : BlockingQueue<InputChannel> from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private inputChannelsWithData : BlockingQueue<InputChannel> from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private consumedResultId : IntermediateDataSetID from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private consumedResultId : IntermediateDataSetID from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private bufferPool : BufferPool from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private bufferPool : BufferPool from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private inputChannels : Map<IntermediateResultPartitionID,InputChannel> from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private inputChannels : Map<IntermediateResultPartitionID,InputChannel> from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private requestLock : Object from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private requestLock : Object from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Move Attribute private pendingEvents : List<TaskEvent> from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private pendingEvents : List<TaskEvent> from class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Variable Type reader1 : BufferReaderBase to reader1 : InputGate in method protected setConfigInputs() : void in class org.apache.flink.streaming.api.streamvertex.CoStreamVertex |
From |
To |
|
Change Variable Type reader : MockIteratorBufferReader<Record> to reader : IteratorWrappingMockSingleInputGate<Record> in method public addInput(inputIterator MutableObjectIterator<Record>) : IteratorWrappingMockSingleInputGate<Record> in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Variable Type readers : BufferReader[] to inputGates : SingleInputGate[] in method public unregisterTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Change Variable Type reader : MockIteratorBufferReader<?> to reader : IteratorWrappingMockSingleInputGate<?> in method public testUnionDataSinkTask() : void in class org.apache.flink.runtime.operators.DataSinkTaskTest |
From |
To |
|
Change Variable Type reader : BufferReader to gate : SingleInputGate in method public registerTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Change Variable Type listener : EventListener<T> to listener : EventListener<TaskEvent> in method public publish(event TaskEvent) : void in class org.apache.flink.runtime.io.network.api.TaskEventHandler |
From |
To |
|
Change Variable Type readers : BufferReader[] to inputGates : SingleInputGate[] in method public registerTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Change Variable Type reader : MockIteratorBufferReader<Record> to reader : IteratorWrappingMockSingleInputGate<Record> in method public addInput(input MutableObjectIterator<Record>, groupId int, read boolean) : IteratorWrappingMockSingleInputGate<Record> in class org.apache.flink.runtime.operators.testutils.TaskTestBase |
From |
To |
|
Change Variable Type inputList1 : ArrayList<BufferReader> to inputList1 : ArrayList<InputGate> in method protected setConfigInputs() : void in class org.apache.flink.streaming.api.streamvertex.CoStreamVertex |
From |
To |
|
Change Variable Type evm : EventNotificationHandler to evm : TaskEventHandler in method public testEventNotificationManager() : void in class org.apache.flink.runtime.util.event.TaskEventHandlerTest |
From |
To |
|
Change Variable Type inputList2 : ArrayList<BufferReader> to inputList2 : ArrayList<InputGate> in method protected setConfigInputs() : void in class org.apache.flink.streaming.api.streamvertex.CoStreamVertex |
From |
To |
|
Change Variable Type reader : MockIteratorBufferReader<Record> to reader : IteratorWrappingMockSingleInputGate<Record> in method public addInput(input MutableObjectIterator<Record>, groupId int) : IteratorWrappingMockSingleInputGate<Record> in class org.apache.flink.runtime.operators.testutils.TaskTestBase |
From |
To |
|
Change Variable Type reader : BufferReader to gate : SingleInputGate in method public unregisterTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Change Variable Type reader2 : BufferReaderBase to reader2 : InputGate in method protected setConfigInputs() : void in class org.apache.flink.streaming.api.streamvertex.CoStreamVertex |
From |
To |
|
Change Variable Type reader : BufferReader to reader : InputGate in method protected setConfigInputs() : void in class org.apache.flink.streaming.api.streamvertex.CoStreamVertex |
From |
To |
|
Change Variable Type nextBuffer : Buffer to boe : BufferOrEvent in method protected getNextRecord(target1 T1, target2 T2) : int in class org.apache.flink.streaming.io.CoRecordReader |
From |
To |
|
Rename Method public getReaderById(id IntermediateDataSetID) : BufferReader renamed to public getInputGateById(id IntermediateDataSetID) : SingleInputGate in class org.apache.flink.runtime.execution.RuntimeEnvironment |
From |
To |
|
Rename Method public getReader(index int) : BufferReader renamed to public getInputGate(index int) : InputGate in class org.apache.flink.runtime.execution.RuntimeEnvironment |
From |
To |
|
Rename Method public getAllReaders() : BufferReader[] renamed to public getAllInputGates() : InputGate[] in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Rename Method public getAllReaders() : BufferReader[] renamed to public getAllInputGates() : InputGate[] in class org.apache.flink.runtime.execution.Environment |
From |
To |
|
Rename Method public getReader(index int) : BufferReader renamed to public getInputGate(index int) : InputGate in class org.apache.flink.runtime.execution.Environment |
From |
To |
|
Rename Method public getReader(index int) : BufferReader renamed to public getInputGate(index int) : InputGate in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Rename Method public getReaders() : BufferReader[] renamed to public getInputGates() : SingleInputGate[] in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Pull Up Method public setIterativeReader() : void from class org.apache.flink.streaming.io.CoRecordReader to public setIterativeReader() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method private incrementEndOfSuperstepEventAndCheck() : boolean from class org.apache.flink.runtime.io.network.api.reader.BufferReader to private incrementEndOfSuperstepEventAndCheck() : boolean from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public startNextSuperstep() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader to public startNextSuperstep() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public hasReachedEndOfSuperstep() : boolean from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public hasReachedEndOfSuperstep() : boolean from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public hasReachedEndOfSuperstep() : boolean from class org.apache.flink.streaming.io.CoRecordReader to public hasReachedEndOfSuperstep() : boolean from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public sendTaskEvent(event TaskEvent) : void from class org.apache.flink.streaming.io.CoRecordReader to public sendTaskEvent(event TaskEvent) : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public isFinished() : boolean from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public isFinished() : boolean from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public subscribeToTaskEvent(listener EventListener<TaskEvent>, eventType Class<? extends TaskEvent>) : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public registerTaskEventListener(listener EventListener<TaskEvent>, eventType Class<? extends TaskEvent>) : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public setIterativeReader() : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public setIterativeReader() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public hasReachedEndOfSuperstep() : boolean from class org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader to public hasReachedEndOfSuperstep() : boolean from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public startNextSuperstep() : void from class org.apache.flink.streaming.io.CoRecordReader to public startNextSuperstep() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public sendTaskEvent(event TaskEvent) : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public sendTaskEvent(event TaskEvent) : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public sendTaskEvent(event TaskEvent) : void from class org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader to public sendTaskEvent(event TaskEvent) : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public isFinished() : boolean from class org.apache.flink.streaming.io.CoRecordReader to public isFinished() : boolean from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public startNextSuperstep() : void from class org.apache.flink.runtime.io.network.api.reader.BufferReader to public startNextSuperstep() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Pull Up Method public setIterativeReader() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader to public setIterativeReader() : void from class org.apache.flink.runtime.io.network.api.reader.AbstractReader |
From |
To |
|
Inline Method package verifyListenerCalled(mockListener EventListener<TaskEvent>, expectedNumCalls int) : void inlined to public testGetNextBufferOrEvent() : void in class org.apache.flink.runtime.io.network.api.reader.BufferReaderTest |
From |
To |
|
Inline Method package consumeAndVerify(reader BufferReaderBase, expectedNumReadBuffers int, expectedNumReadIterations int) : void inlined to public testIterativeGetNextBufferOrEvent() : void in class org.apache.flink.runtime.io.network.api.reader.BufferReaderTest |
From |
To |
|
Inline Method package verifyListenerCalled(mockListener EventListener<TaskEvent>, expectedNumCalls int) : void inlined to public testIterativeGetNextBufferOrEvent() : void in class org.apache.flink.runtime.io.network.api.reader.BufferReaderTest |
From |
To |
|
Inline Method public isFinished() : boolean inlined to protected getNextRecord(target T) : boolean in class org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader |
From |
To |
|
Rename Variable readers : BufferReader[] to inputGates : SingleInputGate[] in method public unregisterTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Rename Variable nextBuffer : Buffer to boe : BufferOrEvent in method protected getNextRecord(target1 T1, target2 T2) : int in class org.apache.flink.streaming.io.CoRecordReader |
From |
To |
|
Rename Variable reader : BufferReader to gate : SingleInputGate in method public registerTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Rename Variable numIterations : int to numEndOfSuperstepEvents : int in method public testIterativeGetNextBufferOrEvent() : void in class org.apache.flink.runtime.io.network.api.reader.BufferReaderTest |
From |
To |
|
Rename Variable readers : BufferReader[] to inputGates : SingleInputGate[] in method public registerTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Rename Variable reader : BufferReader to gate : SingleInputGate in method public unregisterTask(task Task) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Change Return Type MockIteratorBufferReader<Record> to IteratorWrappingMockSingleInputGate<Record> in method public addInput(input MutableObjectIterator<Record>, groupId int, read boolean) : IteratorWrappingMockSingleInputGate<Record> in class org.apache.flink.runtime.operators.testutils.TaskTestBase |
From |
To |
|
Change Return Type MockIteratorBufferReader<Record> to IteratorWrappingMockSingleInputGate<Record> in method public addInput(input MutableObjectIterator<Record>, groupId int) : IteratorWrappingMockSingleInputGate<Record> in class org.apache.flink.runtime.operators.testutils.TaskTestBase |
From |
To |
|
Change Return Type BufferReader[] to InputGate[] in method public getAllInputGates() : InputGate[] in class org.apache.flink.runtime.execution.Environment |
From |
To |
|
Change Return Type BufferReader to SingleInputGate in method public getInputGateById(id IntermediateDataSetID) : SingleInputGate in class org.apache.flink.runtime.execution.RuntimeEnvironment |
From |
To |
|
Change Return Type BufferReader[] to InputGate[] in method public getAllInputGates() : InputGate[] in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Return Type MockIteratorBufferReader<T> to IteratorWrappingMockSingleInputGate<T> in method public read() : IteratorWrappingMockSingleInputGate<T> in class org.apache.flink.runtime.io.network.api.reader.IteratorWrappingMockSingleInputGate |
From |
To |
|
Change Return Type BufferReader to SingleInputGate in method public create(networkEnvironment NetworkEnvironment, desc PartitionConsumerDeploymentDescriptor) : SingleInputGate in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Return Type MockIteratorBufferReader<Record> to IteratorWrappingMockSingleInputGate<Record> in method public addInput(inputIterator MutableObjectIterator<Record>) : IteratorWrappingMockSingleInputGate<Record> in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Return Type BufferReader[] to SingleInputGate[] in method public getInputGates() : SingleInputGate[] in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Return Type BufferReader to InputGate in method public getInputGate(index int) : InputGate in class org.apache.flink.runtime.execution.RuntimeEnvironment |
From |
To |
|
Change Return Type MockIteratorBufferReader<T> to IteratorWrappingMockSingleInputGate<T> in method private wrapIterator(iterator MutableObjectIterator<T>) : IteratorWrappingMockSingleInputGate<T> in class org.apache.flink.runtime.io.network.api.reader.IteratorWrappingMockSingleInputGate |
From |
To |
|
Change Return Type BufferReader to InputGate in method public getInputGate(index int) : InputGate in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Return Type BufferReader to InputGate in method public getInputGate(index int) : InputGate in class org.apache.flink.runtime.execution.Environment |
From |
To |
|
Change Return Type EventNotificationHandler<TaskEvent> to TaskEventHandler in method public getTaskEventHandler() : TaskEventHandler in class org.apache.flink.runtime.io.network.api.writer.BufferWriter |
From |
To |
|
Change Attribute Type bufferReader1 : BufferReaderBase to bufferReader1 : InputGate in class org.apache.flink.streaming.io.CoRecordReader |
From |
To |
|
Change Attribute Type reader : BufferReader to inputGate : SingleInputGate in class org.apache.flink.runtime.io.network.partition.consumer.InputChannel |
From |
To |
|
Change Attribute Type bufferReader2 : BufferReaderBase to bufferReader2 : InputGate in class org.apache.flink.streaming.io.CoRecordReader |
From |
To |
|
Change Attribute Type readers : BufferReader[] to inputGates : SingleInputGate[] in class org.apache.flink.runtime.execution.RuntimeEnvironment |
From |
To |
|
Change Attribute Type inputs : List<BufferReader> to inputs : List<InputGate> in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Attribute Type reader : BufferReaderBase to reader : InputGate in class org.apache.flink.streaming.io.IndexedMutableReader |
From |
To |
|
Change Attribute Type readersById : Map<IntermediateDataSetID,BufferReader> to inputGatesById : Map<IntermediateDataSetID,SingleInputGate> in class org.apache.flink.runtime.execution.RuntimeEnvironment |
From |
To |
|
Change Attribute Type listeners : Multimap<Class<? extends T>,EventListener<T>> to listeners : Multimap<Class<? extends TaskEvent>,EventListener<TaskEvent>> in class org.apache.flink.runtime.io.network.api.TaskEventHandler |
From |
To |
|
Change Attribute Type taskEventHandler : EventNotificationHandler<TaskEvent> to taskEventHandler : TaskEventHandler in class org.apache.flink.runtime.io.network.api.writer.BufferWriter |
From |
To |