|
Change Parameter Type rec1 : Record to rec1 : Tuple2<Integer,String> in method public join(rec1 Tuple2<Integer,String>, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.testutils.MatchRemovingMatcher |
From |
To |
|
Change Parameter Type right : Value to right : String in method public Match(left String, right String) in class org.apache.flink.runtime.operators.testutils.Match |
From |
To |
|
Change Parameter Type leftMap : Map<TestData.Key,Collection<TestData.Value>> to leftMap : Map<Integer,Collection<String>> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Parameter Type leftMap : Map<TestData.Key,Collection<TestData.Value>> to leftMap : Map<Integer,Collection<String>> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Parameter Type out : Collector<Record> to out : Collector<Tuple2<Integer,String>> in method public join(rec1 Tuple2<Integer,String>, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.testutils.MatchRemovingMatcher |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Parameter Type rec2 : Record to rec2 : Tuple2<Integer,String> in method public join(rec1 Tuple2<Integer,String>, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.testutils.MatchRemovingMatcher |
From |
To |
|
Change Parameter Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Parameter Type map : Map<TestData.Key,Collection<Match>> to map : Map<Integer,Collection<Match>> in method public MatchRemovingMatcher(map Map<Integer,Collection<Match>>) in class org.apache.flink.runtime.operators.testutils.MatchRemovingMatcher |
From |
To |
|
Change Parameter Type left : Value to left : String in method public Match(left String, right String) in class org.apache.flink.runtime.operators.testutils.Match |
From |
To |
|
Change Parameter Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<Match>> to entry : Entry<Integer,Collection<Match>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type gen1Iter : TestData.GeneratorIterator to gen1Iter : TestData.TupleGeneratorIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type leftValue : TestData.Value to leftValue : String in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<TestData.Value>> to map : Map<Integer,Collection<String>> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type leftValue : TestData.Value to leftValue : String in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to joinFunction : FlatJoinFunction<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type iterator : ReusingMergeMatchIterator<Record,Record,Record> to iterator : ReusingMergeInnerJoinIterator<Record,Record,Record> in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type expectedMatchesMap : Map<TestData.Key,Collection<Match>> to expectedMatchesMap : Map<Integer,Collection<Match>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type values : Collection<TestData.Value> to values : Collection<String> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type inList2 : List<MutableObjectIterator<Record>> to inList2 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type inList1 : List<MutableObjectIterator<Record>> to inList1 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type const1Iter : TestData.ConstantValueIterator to const1Iter : TestData.TupleConstantValueIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type iterator : NonReusingMergeMatchIterator<Record,Record,Record> to iterator : NonReusingMergeInnerJoinIterator<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type expectedMatchesMap : Map<TestData.Key,Collection<Match>> to expectedMatchesMap : Map<Integer,Collection<Match>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input2 : MutableObjectIterator<Record> to input2 : MutableObjectIterator<Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<Match>> to map : Map<Integer,Collection<Match>> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type iterator : ReusingMergeMatchIterator<Record,Record,Record> to iterator : ReusingMergeInnerJoinIterator<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TupleGenerator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<Match>> to entry : Entry<Integer,Collection<Match>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<Match>> to map : Map<Integer,Collection<Match>> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type values : Collection<TestData.Value> to values : Collection<String> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to joinFunction : FlatJoinFunction<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to joinFunction : FlatJoinFunction<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type gen2Iter : TestData.GeneratorIterator to gen2Iter : TestData.TupleGeneratorIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type leftValues : Collection<TestData.Value> to leftValues : Collection<String> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type pair : Record to pair : Tuple2<Integer,String> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type iterator : ReusingMergeMatchIterator<Record,Record,Record> to iterator : ReusingMergeInnerJoinIterator<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type rightValue : TestData.Value to rightValue : String in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type const1Iter : TestData.ConstantValueIterator to const1Iter : TestData.TupleConstantValueIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type pair : Record to pair : Tuple2<Integer,String> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input2 : MutableObjectIterator<Record> to input2 : MutableObjectIterator<Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type inList1 : List<MutableObjectIterator<Record>> to inList1 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<TestData.Value>> to map : Map<Integer,Collection<String>> in method private collectData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type inList2 : List<MutableObjectIterator<Record>> to inList2 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<Match>> to entry : Entry<Integer,Collection<Match>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type gen1Iter : TestData.GeneratorIterator to gen1Iter : TestData.TupleGeneratorIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TupleGenerator in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input1 : MutableObjectIterator<Record> to input1 : MutableObjectIterator<Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type const2Iter : TestData.ConstantValueIterator to const2Iter : TestData.TupleConstantValueIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type leftValues : Collection<TestData.Value> to leftValues : Collection<String> in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type gen2Iter : TestData.GeneratorIterator to gen2Iter : TestData.TupleGeneratorIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type iterator : NonReusingMergeMatchIterator<Record,Record,Record> to iterator : NonReusingMergeInnerJoinIterator<Tuple2<Integer,String>,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type expectedMatchesMap : Map<TestData.Key,Collection<Match>> to expectedMatchesMap : Map<Integer,Collection<Match>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type rightValue : TestData.Value to rightValue : String in method private matchValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<Match>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type input1 : MutableObjectIterator<Record> to input1 : MutableObjectIterator<Tuple2<Integer,String>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type const2Iter : TestData.ConstantValueIterator to const2Iter : TestData.TupleConstantValueIterator in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<Match>> to entry : Entry<Integer,Collection<Match>> in method public testMergeWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |
|
Change Variable Type expectedMatchesMap : Map<TestData.Key,Collection<Match>> to expectedMatchesMap : Map<Integer,Collection<Match>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeInnerJoinIteratorITCase |
From |
To |