|
Change Parameter Type reuse : Record to reuse : Tuple2<Integer,Integer> in method public next(reuse Tuple2<Integer,Integer>) : Tuple2<Integer,Integer> in class org.apache.flink.runtime.operators.testutils.TestData.ConstantIntIntTuplesIterator |
From |
To |
|
Change Parameter Type iter : Generator to iter : TupleGenerator in method private collectData(iter TupleGenerator, num int) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Parameter Type out : Collector<Record> to out : Collector<Tuple2<Integer,String>> in method public join(rec1 IntPair, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
From |
To |
|
Change Parameter Type candidate : Record to candidate : Tuple2<Integer,String> in method public equalToReference(candidate Tuple2<Integer,String>) : boolean in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.IntPairTuplePairComparator |
From |
To |
|
Change Parameter Type out : Collector<Record> to out : Collector<Tuple2<Integer,String>> in method public join(rec1 IntPair, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
From |
To |
|
Change Parameter Type map : Map<TestData.Key,Collection<RecordIntPairMatch>> to map : Map<Integer,Collection<TupleIntPairMatch>> in method protected TupleIntPairMatchRemovingMatcher(map Map<Integer,Collection<TupleIntPairMatch>>) in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Parameter Type rec2 : Record to rec2 : Tuple2<Integer,String> in method public join(rec1 IntPair, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
From |
To |
|
Change Parameter Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type left : Value to left : String in method public TupleMatch(left String, right String) in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleMatch |
From |
To |
|
Change Parameter Type map : Map<TestData.Key,Collection<RecordMatch>> to map : Map<Integer,Collection<TupleMatch>> in method protected TupleMatchRemovingJoin(map Map<Integer,Collection<TupleMatch>>) in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type candidate : Record to candidate : Tuple2<Integer,String> in method public compareToReference(candidate Tuple2<Integer,String>) : int in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.IntPairTuplePairComparator |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Parameter Type expectedSecondMatchesMap : Map<Key,Collection<RecordMatch>> to expectedSecondMatchesMap : Map<Integer,Collection<TupleMatch>> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type map : Map<TestData.Key,Collection<RecordMatch>> to map : Map<Integer,Collection<TupleMatch>> in method protected TupleMatchRemovingJoin(map Map<Integer,Collection<TupleMatch>>) in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method package collectTupleData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Parameter Type leftMap : Map<TestData.Key,Collection<TestData.Value>> to leftMap : Map<Integer,Collection<String>> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Parameter Type leftMap : Map<TestData.Key,Collection<TestData.Value>> to leftMap : Map<Integer,Collection<String>> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Parameter Type pgen : Generator to pgen : TupleGenerator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
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.hash.NonReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type bgen : Generator to bgen : TestData.TupleGenerator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type serializer : TypeSerializer<Record> to serializer : TypeSerializer<Tuple2<Integer,Integer>> in method private getReducingIterator(data MutableObjectIterator<Tuple2<Integer,Integer>>, serializer TypeSerializer<Tuple2<Integer,Integer>>, comparator TypeComparator<Tuple2<Integer,Integer>>) : Iterator<Integer> in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Parameter Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method package collectTupleData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Parameter Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type comparator : TypeComparator<Record> to comparator : TypeComparator<Tuple2<Integer,Integer>> in method private getReducingIterator(data MutableObjectIterator<Tuple2<Integer,Integer>>, serializer TypeSerializer<Tuple2<Integer,Integer>>, comparator TypeComparator<Tuple2<Integer,Integer>>) : Iterator<Integer> in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Parameter Type leftMap : Map<TestData.Key,Collection<TestData.Value>> to leftMap : Map<Integer,Collection<String>> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
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.hash.ReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type right : Value to right : String in method public TupleMatch(left String, right String) in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleMatch |
From |
To |
|
Change Parameter Type values : Iterable<Record> to values : Iterable<Tuple2<Integer,String>> in method public combine(values Iterable<Tuple2<Integer,String>>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase.TestCountCombiner2 |
From |
To |
|
Change Parameter Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type right : Value to right : String in method public TupleIntPairMatch(left int, right String) in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleIntPairMatch |
From |
To |
|
Change Parameter Type right : Value to right : String in method public TupleIntPairMatch(left int, right String) in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleIntPairMatch |
From |
To |
|
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.hash.NonReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type reference : Record to reference : Tuple2<Integer,String> in method public setReference(reference Tuple2<Integer,String>) : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleIntPairPairComparator |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Parameter Type candidate : Record to candidate : Tuple2<Integer,String> in method public compareToReference(candidate Tuple2<Integer,String>) : int in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.IntPairTuplePairComparator |
From |
To |
|
Change Parameter Type bgen : Generator to bgen : TupleGenerator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type iter : Generator to iter : TupleGenerator in method private collectData(iter TupleGenerator, num int) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Parameter Type map : Map<TestData.Key,Collection<RecordIntPairMatch>> to map : Map<Integer,Collection<TupleIntPairMatch>> in method protected TupleIntPairMatchRemovingMatcher(map Map<Integer,Collection<TupleIntPairMatch>>) in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
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.hash.ReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type candidate : Record to candidate : Tuple2<Integer,String> in method public equalToReference(candidate Tuple2<Integer,String>) : boolean in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.IntPairTuplePairComparator |
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.hash.NonReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type expectedSecondMatchesMap : Map<Key,Collection<RecordMatch>> to expectedSecondMatchesMap : Map<Integer,Collection<TupleMatch>> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type reference : Record to reference : Tuple2<Integer,String> in method public setReference(reference Tuple2<Integer,String>) : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleIntPairPairComparator |
From |
To |
|
Change Parameter Type data : MutableObjectIterator<Record> to data : MutableObjectIterator<Tuple2<Integer,Integer>> in method private getReducingIterator(data MutableObjectIterator<Tuple2<Integer,Integer>>, serializer TypeSerializer<Tuple2<Integer,Integer>>, comparator TypeComparator<Tuple2<Integer,Integer>>) : Iterator<Integer> in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Parameter Type rec2 : Record to rec2 : Tuple2<Integer,String> in method public join(rec1 IntPair, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
From |
To |
|
Change Parameter Type left : Value to left : String in method public TupleMatch(left String, right String) in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleMatch |
From |
To |
|
Change Parameter Type out : Collector<Record> to out : Collector<Tuple2<Integer,String>> in method public combine(values Iterable<Tuple2<Integer,String>>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase.TestCountCombiner2 |
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.hash.ReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Parameter Type leftMap : Map<TestData.Key,Collection<TestData.Value>> to leftMap : Map<Integer,Collection<String>> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Parameter Type rightMap : Map<TestData.Key,Collection<TestData.Value>> to rightMap : Map<Integer,Collection<String>> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Parameter Type pgen : Generator to pgen : TestData.TupleGenerator in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Parameter Type right : Value to right : String in method public TupleMatch(left String, right String) in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleMatch |
From |
To |
|
Change Variable Type probeRec : Record to probeRec : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type o : RecordIntPairMatch to o : TupleIntPairMatch in method public equals(obj Object) : boolean in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleIntPairMatch |
From |
To |
|
Change Variable Type o : RecordIntPairMatch to o : TupleIntPairMatch in method public equals(obj Object) : boolean in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleIntPairMatch |
From |
To |
|
Change Variable Type gen1Iter : TestData.GeneratorIterator to gen1Iter : TestData.TupleGeneratorIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type inList2 : List<MutableObjectIterator<Record>> to inList2 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type inList1 : List<MutableObjectIterator<Record>> to inList1 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matcher : FlatJoinFunction<IntPair,Record,Record> to matcher : FlatJoinFunction<IntPair,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type source : MutableObjectIterator<Record> to source : MutableObjectIterator<Tuple2<Integer,String>> in method public testSpillingSortWithIntermediateMerge() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type probes : List<MutableObjectIterator<Record>> to probes : List<MutableObjectIterator<Tuple2<Integer,Integer>>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type expValues2 : Collection<TestData.Value> to expValues2 : Collection<String> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type input2 : MutableObjectIterator<Record> to input2 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TestData.TupleGenerator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type v1 : TestData.Value to v1 : String in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type gen1Iter : TestData.GeneratorIterator to gen1Iter : TestData.TupleGeneratorIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteReadNotAll() : void in class org.apache.flink.runtime.io.disk.ChannelViewsTest |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TestData.TupleGenerator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<TestData.Value>> to map : Map<Integer,Collection<String>> in method package collectTupleData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type const1Iter : TestData.ConstantValueIterator to const1Iter : TestData.TupleConstantValueIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type tmp : Map<TestData.Key,Collection<RecordMatch>> to tmp : Map<Integer,Collection<TupleMatch>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type expectedCoGroupsMap : Map<TestData.Key,List<Collection<TestData.Value>>> to expectedCoGroupsMap : Map<Integer,List<Collection<String>>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type inList2 : List<MutableObjectIterator<Record>> to inList2 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type copy : Map<Key,Collection<RecordMatch>> to copy : Map<Integer,Collection<TupleMatch>> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type expectedValuesMap1 : Map<TestData.Key,Collection<TestData.Value>> to expectedStringsMap1 : Map<Integer,Collection<String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testCombine() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type v2 : TestData.Value to v2 : String in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type inList2 : List<MutableObjectIterator<Record>> to inList2 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testSortShortStringKeys() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type build3 : MutableObjectIterator<Record> to build3 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type firstMatcher : JoinFunction to firstMatcher : FlatJoinFunction in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testSpillingSort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TupleGenerator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type const1Iter : TestData.ConstantValueIterator to const1Iter : TestData.TupleConstantValueIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type builds : List<MutableObjectIterator<Record>> to builds : List<MutableObjectIterator<Tuple2<Integer,Integer>>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testInMemorySort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteReadSmallRecords() : void in class org.apache.flink.runtime.io.disk.ChannelViewsTest |
From |
To |
|
Change Variable Type matches : Collection<RecordMatch> to matches : Collection<TupleMatch> 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.hash.ReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Variable Type expectedNMatchesMapList : List<Map<Key,Collection<RecordMatch>>> to expectedNMatchesMapList : List<Map<Integer,Collection<TupleMatch>>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type probeRec : Record to probeRec : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type inList1 : List<MutableObjectIterator<Record>> to inList1 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type merger : Sorter<Record> to merger : Sorter<Tuple2<Integer,String>> in method public testSpillingSortWithIntermediateMerge() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type tmp : Map<Key,Collection<RecordMatch>> to tmp : Map<Integer,Collection<TupleMatch>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type leftValue : TestData.Value to leftValue : String in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method public testSort() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type builds : List<MutableObjectIterator<Record>> to builds : List<MutableObjectIterator<Tuple2<Integer,Integer>>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type o : RecordMatch to o : TupleMatch in method public equals(obj Object) : boolean in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleMatch |
From |
To |
|
Change Variable Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type probeRec : Record to probeRec : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type probe2 : MutableObjectIterator<Record> to probe2 : MutableObjectIterator<Tuple2<Integer,Integer>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteReadOneBufferOnly() : void in class org.apache.flink.runtime.io.disk.ChannelViewsTest |
From |
To |
|
Change Variable Type gen2Iter : TestData.GeneratorIterator to gen2Iter : TestData.TupleGeneratorIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<RecordMatch>> to map : Map<Integer,Collection<TupleMatch>> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input2 : MutableObjectIterator<Record> to input2 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type builds : List<MutableObjectIterator<Record>> to builds : List<MutableObjectIterator<Tuple2<Integer,Integer>>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type inList1 : List<MutableObjectIterator<Record>> to inList1 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type build3 : MutableObjectIterator<Record> to build3 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type const1Iter : TestData.ConstantValueIterator to const1Iter : TestData.TupleConstantValueIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type firstMatcher : JoinFunction to firstMatcher : FlatJoinFunction in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type pgen : Generator to pgen : TupleGenerator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type gen1Iter : TestData.GeneratorIterator to gen1Iter : TestData.TupleGeneratorIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type inList2 : List<MutableObjectIterator<Record>> to inList2 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type iter2 : Iterator<Record> to iter2 : Iterator<Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type rec : Record to rec : Tuple2<Integer,String> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type const2Iter : TestData.ConstantValueIterator to const2Iter : TestData.TupleConstantValueIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<TestData.Value>> to map : Map<Integer,Collection<String>> in method package collectTupleData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type values : Collection<TestData.Value> to values : Collection<String> in method package collectTupleData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type record : Record to record : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type iterators : List<MutableObjectIterator<Record>> to iterators : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testMergeOfTwoStreams() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type m : RecordMatch to m : TupleMatch in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type value : Value to value : String in method private newIterator(keys int[], values String[]) : MutableObjectIterator<Tuple2<Integer,String>> in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type probes : List<MutableObjectIterator<Record>> to probes : List<MutableObjectIterator<Tuple2<Integer,Integer>>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildInput : MutableObjectIterator<Record> to buildInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<TestData.Value>> to map : Map<Integer,Collection<String>> in method private collectData(iter TupleGenerator, num int) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type v2 : TestData.Value to v2 : String in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testCombineSpilling() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type iter1 : Iterator<Record> to iter1 : Iterator<Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type leftValue : TestData.Value to leftValue : String in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type probe1 : MutableObjectIterator<Record> to probe1 : MutableObjectIterator<Tuple2<Integer,Integer>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method public testSortLongStringKeys() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type leftValues : Collection<TestData.Value> to leftValues : Collection<String> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type sortedInput2 : MutableObjectIterator<Record> to sortedInput2 : MutableObjectIterator<Tuple2<Integer,String>> in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteReadTooMuchExternal() : void in class org.apache.flink.runtime.io.disk.SpillingBufferTest |
From |
To |
|
Change Variable Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type iter2 : Iterator<Record> to iter2 : Iterator<Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type rec : Record to rec : Tuple2<Integer,String> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type build3 : MutableObjectIterator<Record> to build3 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type matchedValues : Collection<RecordIntPairMatch> to matchedValues : Collection<TupleIntPairMatch> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type pgen : Generator to pgen : TestData.TupleGenerator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildInput : MutableObjectIterator<Record> to buildInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type rightValue : TestData.Value to rightValue : String in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type pgen : Generator to pgen : TupleGenerator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type bgen : Generator to bgen : TupleGenerator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type tmp : Record to tmp : Tuple2<Integer,String> in method public testSpillingSortWithIntermediateMerge() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type values : Collection<TestData.Value> to values : Collection<String> in method private collectData(iter TupleGenerator, num int) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testReset() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type matcher : FlatJoinFunction<IntPair,Record,Record> to matcher : FlatJoinFunction<IntPair,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testSortAndValidate() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testSortLongStringKeys() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type build2 : MutableObjectIterator<Record> to build2 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteAndReadLongRecords() : void in class org.apache.flink.runtime.io.disk.ChannelViewsTest |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testInMemorySortUsing10Buffers() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type merger : Sorter<Record> to merger : Sorter<Tuple2<Integer,String>> in method public testInMemorySortUsing10Buffers() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type matchedValues : Collection<RecordIntPairMatch> to matchedValues : Collection<TupleIntPairMatch> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type gen1Iter : TestData.GeneratorIterator to gen1Iter : TestData.TupleGeneratorIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type record : Record to record : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type iterators : List<MutableObjectIterator<Record>> to iterators : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testMergeOfTenStreams() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type val : TestData.Value to val : String in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matcher : FlatJoinFunction<IntPair,Record,Record> to matcher : FlatJoinFunction<IntPair,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type source : MutableObjectIterator<Record> to source : MutableObjectIterator<Tuple2<Integer,String>> in method public testInMemorySortUsing10Buffers() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testMergeOfTwoStreams() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type build2 : MutableObjectIterator<Record> to build2 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type buildInput : MutableObjectIterator<Record> to buildInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TupleGenerator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type merger : Sorter<Record> to merger : Sorter<Tuple2<Integer,String>> in method public testSortAndValidate() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type pgen : Generator to pgen : TupleGenerator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type keySet : Set<TestData.Key> to keySet : Set<Integer> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type matcher : FlatJoinFunction<IntPair,Record,Record> to matcher : FlatJoinFunction<IntPair,Tuple2<Integer,String>,Tuple2<Integer,String>> in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteReadExternal() : void in class org.apache.flink.runtime.io.disk.SpillingBufferTest |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type reuse : Record to reuse : Tuple2<Integer,String> in method private newIterator(keys int[], values String[]) : MutableObjectIterator<Tuple2<Integer,String>> in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type pgen : Generator to pgen : TestData.TupleGenerator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matches : List<RecordMatch> to matches : List<TupleMatch> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type matchedValues : Collection<RecordMatch> to matchedValues : Collection<TupleMatch> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type sortedInput1 : MutableObjectIterator<Record> to sortedInput1 : MutableObjectIterator<Tuple2<Integer,String>> in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type input1 : MutableObjectIterator<Record> to input1 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type probe1 : MutableObjectIterator<Record> to probe1 : MutableObjectIterator<Tuple2<Integer,Integer>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testSpillingSort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<RecordIntPairMatch>> to map : Map<Integer,Collection<TupleIntPairMatch>> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type bgen : Generator to bgen : TestData.TupleGenerator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testInvalidMerge() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type leftValues : Collection<TestData.Value> to leftValues : Collection<String> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testInMemorySort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TupleGenerator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type gen2Iter : TestData.GeneratorIterator to gen2Iter : TestData.TupleGeneratorIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type const2Iter : TestData.ConstantValueIterator to const2Iter : TestData.TupleConstantValueIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type val : TestData.Value to val : String in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type source : MutableObjectIterator<Record> to source : MutableObjectIterator<Tuple2<Integer,String>> in method public testSpillingSort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type expectedValuesMap1 : Map<TestData.Key,Collection<TestData.Value>> to expectedValuesMap1 : Map<Integer,Collection<String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type next : Record to next : Tuple2<Integer,String> in method public combine(values Iterable<Tuple2<Integer,String>>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase.TestCountCombiner2 |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type source : MutableObjectIterator<Record> to source : MutableObjectIterator<Tuple2<Integer,String>> in method public testInMemorySort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type probe2 : MutableObjectIterator<Record> to probe2 : MutableObjectIterator<Tuple2<Integer,Integer>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type input2 : MutableObjectIterator<Record> to input2 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testMergeOfTenStreams() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type o : RecordMatch to o : TupleMatch in method public equals(obj Object) : boolean in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleMatch |
From |
To |
|
Change Variable Type map : Map<TestData.Key,List<Collection<TestData.Value>>> to map : Map<Integer,List<Collection<String>>> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type pgen : Generator to pgen : TestData.TupleGenerator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteAndRead() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<RecordIntPairMatch>> to map : Map<Integer,Collection<TupleIntPairMatch>> in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type result : Record to result : Tuple2<Integer,String> in method private newIterator(keys int[], values String[]) : MutableObjectIterator<Tuple2<Integer,String>> in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type const1Iter : TestData.ConstantValueIterator to const1Iter : TestData.TupleConstantValueIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type probeRec : Record to probeRec : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type buildInput : TestData.GeneratorIterator to buildInput : TestData.TupleGeneratorIterator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type expValues1 : Collection<TestData.Value> to expValues1 : Collection<String> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TestData.TupleGenerator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type tmp : Record to tmp : Tuple2<Integer,String> in method public testInvalidMerge() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type buildSide : HashBucketIterator<Record,Record> to buildSide : HashBucketIterator<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type gen2Iter : TestData.GeneratorIterator to gen2Iter : TestData.TupleGeneratorIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordMatch>> to entry : Entry<Integer,Collection<TupleMatch>> in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iterators : List<MutableObjectIterator<Record>> to iterators : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testInvalidMerge() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type matches : Collection<RecordIntPairMatch> to matches : Collection<TupleIntPairMatch> in method public join(rec1 IntPair, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
From |
To |
|
Change Variable Type tmp : Record to tmp : Tuple2<Integer,String> in method public testMergeOfTwoStreams() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type bgen : Generator to bgen : TestData.TupleGenerator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testSpillingSortWithIntermediateMerge() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type merger : Sorter<Record> to merger : Sorter<Tuple2<Integer,Integer>> in method public testCombineSpilling() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type build1 : MutableObjectIterator<Record> to build1 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testReadWithoutKnownBlockCount() : void in class org.apache.flink.runtime.io.disk.ChannelViewsTest |
From |
To |
|
Change Variable Type iter1 : Iterator<Record> to iter1 : Iterator<Tuple2<Integer,String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type build1 : MutableObjectIterator<Record> to build1 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type build1 : MutableObjectIterator<Record> to build1 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type copy : Map<Key,Collection<RecordMatch>> to copy : Map<Integer,Collection<TupleMatch>> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type expectedValuesMap2 : Map<TestData.Key,Collection<TestData.Value>> to expectedValuesMap2 : Map<Integer,Collection<String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type const2Iter : TestData.ConstantValueIterator to const2Iter : TestData.TupleConstantValueIterator in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type leftValues : Collection<TestData.Value> to leftValues : Collection<String> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<RecordMatch>> to map : Map<Integer,Collection<TupleMatch>> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type key : Key to key : int in method private newIterator(keys int[], values String[]) : MutableObjectIterator<Tuple2<Integer,String>> in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testInMemorySortUsing10Buffers() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type values : Collection<TestData.Value> to values : Collection<String> in method private collectData(iter TupleGenerator, num int) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type expValues1 : Collection<TestData.Value> to expValues1 : Collection<String> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type merger : Sorter<Record> to merger : Sorter<Tuple2<Integer,Integer>> in method public testCombine() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type const2Iter : TestData.ConstantValueIterator to const2Iter : TestData.TupleConstantValueIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matchedValues : Collection<RecordMatch> to matchedValues : Collection<TupleMatch> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type probeInput : TestData.GeneratorIterator to probeInput : TestData.TupleGeneratorIterator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type keySet : Set<TestData.Key> to keySet : Set<Integer> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type probeInput : MutableObjectIterator<Record> to probeInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type tmp : Record to tmp : Tuple2<Integer,String> in method public testSpillingSort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type build1 : MutableObjectIterator<Record> to build1 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type bgen : Generator to bgen : TupleGenerator in method public testDoubleProbeInMemory() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TupleGenerator, pgen TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type matches : List<RecordMatch> to matches : List<TupleMatch> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordIntPairMatch>> to entry : Entry<Integer,Collection<TupleIntPairMatch>> in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordIntPairMatch>> to entry : Entry<Integer,Collection<TupleIntPairMatch>> in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,Collection<TestData.Value>> to map : Map<Integer,Collection<String>> in method private collectData(iter TupleGenerator, num int) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type inList1 : List<MutableObjectIterator<Record>> to inList1 : List<MutableObjectIterator<Tuple2<Integer,String>>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type tmp : Record to tmp : Tuple2<Integer,String> in method public testInMemorySort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TupleGenerator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method public testSortShortStringKeys() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type sorter : NormalizedKeySorter<Record> to sorter : NormalizedKeySorter<Tuple2<Integer,String>> in method public testCompare() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type probeInput : MutableObjectIterator<Record> to probeInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type expectedValuesMap2 : Map<TestData.Key,Collection<TestData.Value>> to expectedStringsMap2 : Map<Integer,Collection<String>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type expectedCoGroupsMap : Map<TestData.Key,List<Collection<TestData.Value>>> to expectedCoGroupsMap : Map<Integer,List<Collection<String>>> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteReadTooMuchInMemory() : void in class org.apache.flink.runtime.io.disk.SpillingBufferTest |
From |
To |
|
Change Variable Type input1 : TestData.GeneratorIterator to input1 : TestData.TupleGeneratorIterator in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TestData.TupleGenerator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testReadTooMany() : void in class org.apache.flink.runtime.io.disk.ChannelViewsTest |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Map.Entry<Key,Collection<RecordMatch>> to entry : Map.Entry<Integer,Collection<TupleMatch>> in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type leftValues : Collection<TestData.Value> to leftValues : Collection<String> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testSort() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type bgen : Generator to bgen : TestData.TupleGenerator in method public testOverflow() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type tmp : Record to tmp : Tuple2<Integer,String> in method public testMergeOfTenStreams() : void in class org.apache.flink.runtime.operators.sort.MergeIteratorTest |
From |
To |
|
Change Variable Type input1 : MutableObjectIterator<Record> to input1 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matches : Collection<RecordMatch> to matches : Collection<TupleMatch> 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.hash.NonReusingHashMatchIteratorITCase.TupleMatchRemovingJoin |
From |
To |
|
Change Variable Type bgen : Generator to bgen : TupleGenerator in method public testDoubleProbeSpilling() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type sorter : NormalizedKeySorter<Record> to sorter : NormalizedKeySorter<Tuple2<Integer,String>> in method public testReset() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type builds : List<MutableObjectIterator<Record>> to builds : List<MutableObjectIterator<Tuple2<Integer,Integer>>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type iterator : MutableObjectIterator<Record> to iterator : MutableObjectIterator<Tuple2<Integer,String>> in method public testSpillingSortWithIntermediateMerge() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type merger : Sorter<Record> to merger : Sorter<Tuple2<Integer,String>> in method public testSpillingSort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type probeInput : MutableObjectIterator<Record> to probeInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testSwap() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type buildInput : MutableObjectIterator<Record> to buildInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type merger : Sorter<Record> to merger : Sorter<Tuple2<Integer,String>> in method public testInMemorySort() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type probe3 : MutableObjectIterator<Record> to probe3 : MutableObjectIterator<Tuple2<Integer,Integer>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type input2 : TestData.GeneratorIterator to input2 : TestData.TupleGeneratorIterator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type build2 : MutableObjectIterator<Record> to build2 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type sorter : NormalizedKeySorter<Record> to sorter : NormalizedKeySorter<Tuple2<Integer,String>> in method public testSort() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type v1 : TestData.Value to v1 : String in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type input2 : MutableObjectIterator<Record> to input2 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iter : MutableObjectIterator<Record> to iter : MutableObjectIterator<Tuple2<Integer,String>> in method public testWriteAndIterator() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type probe3 : MutableObjectIterator<Record> to probe3 : MutableObjectIterator<Tuple2<Integer,Integer>> in method private getProbeInput(numKeys int, probeValsPerKey int, repeatedValue1 int, repeatedValue2 int) : MutableObjectIterator<Tuple2<Integer,Integer>> in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type sorter : NormalizedKeySorter<Record> to sorter : NormalizedKeySorter<Tuple2<Integer,String>> in method public testWriteAndIterator() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteReadInMemory() : void in class org.apache.flink.runtime.io.disk.SpillingBufferTest |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TestData.TupleGenerator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type expValues2 : Collection<TestData.Value> to expValues2 : Collection<String> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type values : Iterator<Record> to values : Iterator<Tuple2<Integer,Integer>> in method public next() : Integer in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase.getReducingIterator |
From |
To |
|
Change Variable Type record : Record to record : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type key : TestData.Key to key : Integer in method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type sorter : NormalizedKeySorter<Record> to sorter : NormalizedKeySorter<Tuple2<Integer,String>> in method public testSwap() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type matcher : JoinFunction to matcher : FlatJoinFunction in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matches : Collection<RecordIntPairMatch> to matches : Collection<TupleIntPairMatch> in method public join(rec1 IntPair, rec2 Tuple2<Integer,String>, out Collector<Tuple2<Integer,String>>) : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase.TupleIntPairMatchRemovingMatcher |
From |
To |
|
Change Variable Type input1 : MutableObjectIterator<Record> to input1 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type gen2Iter : TestData.GeneratorIterator to gen2Iter : TestData.TupleGeneratorIterator in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testWriteAndIterator() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type tmp : Record to tmp : Tuple2<Integer,String> in method public testInMemorySortUsing10Buffers() : void in class org.apache.flink.runtime.operators.sort.ExternalSortITCase |
From |
To |
|
Change Variable Type generator2 : Generator to generator2 : TupleGenerator in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type sorter : NormalizedKeySorter<Record> to sorter : NormalizedKeySorter<Tuple2<Integer,String>> in method public testWriteAndRead() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type values : Collection<TestData.Value> to values : Collection<String> in method package collectTupleData(iter MutableObjectIterator<Tuple2<Integer,String>>) : Map<Integer,Collection<String>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type probeInput : MutableObjectIterator<Record> to probeInput : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type input1 : MutableObjectIterator<Record> to input1 : MutableObjectIterator<Tuple2<Integer,String>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testSortAndValidate() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TestData.TupleGenerator in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordIntPairMatch>> to entry : Entry<Integer,Collection<TupleIntPairMatch>> in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type entry : Entry<TestData.Key,Collection<RecordIntPairMatch>> to entry : Entry<Integer,Collection<TupleIntPairMatch>> in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TestData.TupleGenerator in method public testSortBothMerge() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type record : Record to record : Tuple2<Integer,Integer> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type m : RecordMatch to m : TupleMatch in method package deepCopy(expectedSecondMatchesMap Map<Integer,Collection<TupleMatch>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type rightValues : Collection<TestData.Value> to rightValues : Collection<String> in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type expectedNMatchesMapList : List<Map<TestData.Key,Collection<RecordMatch>>> to expectedNMatchesMapList : List<Map<Integer,Collection<TupleMatch>>> in method private doTest(buildInput TestData.TupleGeneratorIterator, probeInput TestData.TupleGeneratorIterator, bgen TestData.TupleGenerator, pgen TestData.TupleGenerator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type collector : Collector<Record> to collector : Collector<Tuple2<Integer,String>> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type generator : TestData.Generator to generator : TestData.TupleGenerator in method public testCompare() : void in class org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest |
From |
To |
|
Change Variable Type rightValue : TestData.Value to rightValue : String in method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type map : Map<TestData.Key,List<Collection<TestData.Value>>> to map : Map<Integer,List<Collection<String>>> in method private coGroupValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,List<Collection<String>>> in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type build2 : MutableObjectIterator<Record> to build2 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithMassiveCollisions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type build3 : MutableObjectIterator<Record> to build3 : MutableObjectIterator<Tuple2<Integer,Integer>> in method public testSpillingHashJoinWithTwoRecursions() : void in class org.apache.flink.runtime.operators.hash.NonReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type generator1 : Generator to generator1 : TestData.TupleGenerator in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |