|
Rename Parameter matchFunction : FlatJoinFunction<T1,T2,O> to joinFunction : FlatJoinFunction<T1,T2,O> in method private crossSecond1withNValues(val1 T2, firstValN T1, valsN Iterator<T1>, joinFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Rename Parameter matchFunction : FlatJoinFunction<T1,T2,O> to joinFunction : FlatJoinFunction<T1,T2,O> in method public abstract callWithNextKey(joinFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : boolean in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Rename Parameter matchFunction : FlatJoinFunction<T1,T2,O> to joinFunction : FlatJoinFunction<T1,T2,O> in method protected crossMatchingGroup(values1 Iterator<T1>, values2 Iterator<T2>, joinFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Rename Parameter matchFunction : FlatJoinFunction<T1,T2,O> to joinFunction : FlatJoinFunction<T1,T2,O> in method private crossFirst1withNValues(val1 T1, firstValN T2, valsN Iterator<T2>, joinFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |
|
Rename Parameter matchFunction : FlatJoinFunction<T1,T2,O> to joinFunction : FlatJoinFunction<T1,T2,O> in method private crossMwithNValues(firstV1 T1, spillVals Iterator<T1>, firstV2 T2, blockVals Iterator<T2>, joinFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : void in class org.apache.flink.runtime.operators.sort.AbstractMergeIterator |
From |
To |