|
Move Method public abort() : void from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to public abort() : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method public open() : void from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to public open() : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method private crossSecond1withNValues(val1 T2, firstValN T1, valsN Iterator<T1>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private crossSecond1withNValues(val1 T2, firstValN T1, valsN Iterator<T1>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method private crossSecond1withNValues(val1 T2, firstValN T1, valsN Iterator<T1>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private crossSecond1withNValues(val1 T2, firstValN T1, valsN Iterator<T1>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method private crossMwithNValues(firstV1 T1, spillVals Iterator<T1>, firstV2 T2, blockVals Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private crossMwithNValues(firstV1 T1, spillVals Iterator<T1>, firstV2 T2, blockVals Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method private crossFirst1withNValues(val1 T1, firstValN T2, valsN Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private crossFirst1withNValues(val1 T1, firstValN T2, valsN Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method private crossFirst1withNValues(val1 T1, firstValN T2, valsN Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private crossFirst1withNValues(val1 T1, firstValN T2, valsN Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method private crossMwithNValues(firstV1 T1, spillVals Iterator<T1>, firstV2 T2, blockVals Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private crossMwithNValues(firstV1 T1, spillVals Iterator<T1>, firstV2 T2, blockVals Iterator<T2>, matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method public abort() : void from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to public abort() : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method public close() : void from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to public close() : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method public open() : void from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to public open() : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Method public close() : void from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to public close() : void from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private spillHeadCopy : T1 from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to protected spillHeadCopy : T1 from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private blockHeadCopy : T2 from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to protected blockHeadCopy : T2 from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private memoryManager : MemoryManager from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private memoryManager : MemoryManager from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private copy2 : T2 from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to protected copy2 : T2 from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private ioManager : IOManager from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private ioManager : IOManager from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private memoryForSpillingIterator : List<MemorySegment> from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private memoryForSpillingIterator : List<MemorySegment> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private blockIt : NonReusingBlockResettableIterator<T2> from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private blockIt : NonReusingBlockResettableIterator<T2> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private LOG : Logger from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private LOG : Logger from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private serializer2 : TypeSerializer<T2> from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to protected serializer2 : TypeSerializer<T2> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private blockIt : NonReusingBlockResettableIterator<T2> from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private blockIt : NonReusingBlockResettableIterator<T2> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private memoryForSpillingIterator : List<MemorySegment> from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private memoryForSpillingIterator : List<MemorySegment> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private LOG : Logger from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to private LOG : Logger from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private copy1 : T1 from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to protected copy1 : T1 from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private serializer2 : TypeSerializer<T2> from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to protected serializer2 : TypeSerializer<T2> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private ioManager : IOManager from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private ioManager : IOManager from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private serializer1 : TypeSerializer<T1> from class org.apache.flink.runtime.operators.sort.NonReusingMergeMatchIterator to protected serializer1 : TypeSerializer<T1> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private serializer1 : TypeSerializer<T1> from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to protected serializer1 : TypeSerializer<T1> from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Move Attribute private memoryManager : MemoryManager from class org.apache.flink.runtime.operators.sort.ReusingMergeMatchIterator to private memoryManager : MemoryManager from class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |