|
Pull Up Method public getHashJoin(buildSideSerializer TypeSerializer<BT>, buildSideComparator TypeComparator<BT>, probeSideSerializer TypeSerializer<PT>, probeSideComparator TypeComparator<PT>, pairComparator TypePairComparator<PT,BT>, memManager MemoryManager, ioManager IOManager, ownerTask AbstractInvokable, memoryFraction double) : MutableHashTable<BT,PT> from class org.apache.flink.runtime.operators.hash.BuildSecondHashMatchIterator to public getHashJoin(buildSideSerializer TypeSerializer<BT>, buildSideComparator TypeComparator<BT>, probeSideSerializer TypeSerializer<PT>, probeSideComparator TypeComparator<PT>, pairComparator TypePairComparator<PT,BT>, memManager MemoryManager, ioManager IOManager, ownerTask AbstractInvokable, memoryFraction double) : MutableHashTable<BT,PT> from class org.apache.flink.runtime.operators.hash.HashMatchIteratorBase |
From |
To |
|
Pull Up Method public getHashJoin(buildSideSerializer TypeSerializer<BT>, buildSideComparator TypeComparator<BT>, probeSideSerializer TypeSerializer<PT>, probeSideComparator TypeComparator<PT>, pairComparator TypePairComparator<PT,BT>, memManager MemoryManager, ioManager IOManager, ownerTask AbstractInvokable, memoryFraction double) : MutableHashTable<BT,PT> from class org.apache.flink.runtime.operators.hash.BuildFirstHashMatchIterator to public getHashJoin(buildSideSerializer TypeSerializer<BT>, buildSideComparator TypeComparator<BT>, probeSideSerializer TypeSerializer<PT>, probeSideComparator TypeComparator<PT>, pairComparator TypePairComparator<PT,BT>, memManager MemoryManager, ioManager IOManager, ownerTask AbstractInvokable, memoryFraction double) : MutableHashTable<BT,PT> from class org.apache.flink.runtime.operators.hash.HashMatchIteratorBase |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.BuildSecondHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildSecondHashMatchIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.util.KeyGroupedIteratorImmutable renamed to org.apache.flink.runtime.util.NonReusingKeyGroupedIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.HashMatchIteratorITCase renamed to org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Rename Class org.apache.flink.runtime.util.MutableToRegularIteratorWrapper renamed to org.apache.flink.runtime.util.ReusingMutableToRegularIteratorWrapper |
From |
To |
|
Rename Class org.apache.flink.runtime.util.KeyGroupedIteratorImmutableTest renamed to org.apache.flink.runtime.util.NonReusingKeyGroupedIteratorTest |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.sort.SortMergeCoGroupIteratorITCase renamed to org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.sort.SortMergeCoGroupIterator renamed to org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.BuildSecondReOpenableHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildSecondReOpenableHashMatchIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.util.KeyGroupedIterator renamed to org.apache.flink.runtime.util.ReusingKeyGroupedIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.ReOpenableHashTableITCase renamed to org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.BuildFirstReOpenableHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildFirstReOpenableHashMatchIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.util.KeyGroupedIteratorTest renamed to org.apache.flink.runtime.util.ReusingKeyGroupedIteratorTest |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.BuildFirstHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildFirstHashMatchIterator |
From |
To |
|
Change Variable Type values2 : KeyGroupedIterator<T2> to values2 : ReusingKeyGroupedIterator<T2> in method public callWithNextKey(matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : boolean in class org.apache.flink.runtime.operators.sort.MergeMatchIterator |
From |
To |
|
Change Variable Type iterator : BuildSecondHashMatchIterator<Record,Record,Record> to iterator : ReusingBuildSecondHashMatchIterator<Record,Record,Record> in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iterator : BuildSecondHashMatchIterator<Record,Record,Record> to iterator : ReusingBuildSecondHashMatchIterator<Record,Record,Record> in method public testBuildSecond() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type keyIter : KeyGroupedIterator<T> to keyIter : ReusingKeyGroupedIterator<T> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type groupedIter : KeyGroupedIterator<E> to groupedIter : ReusingKeyGroupedIterator<E> in method protected mergeChannels(channelIDs List<ChannelWithBlockCount>, readBuffers List<List<MemorySegment>>, writeBuffers List<MemorySegment>) : ChannelWithBlockCount in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger.CombiningSpillingThread |
From |
To |
|
Change Variable Type iterator : BuildFirstHashMatchIterator<Record,Record,Record> to iterator : ReusingBuildFirstHashMatchIterator<Record,Record,Record> in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.util.HashVsSortMiniBenchmark |
From |
To |
|
Change Variable Type iterator : BuildFirstHashMatchIterator<Record,Record,Record> to iterator : ReusingBuildFirstHashMatchIterator<Record,Record,Record> in method public testBuildFirstWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type matchIterator : BuildSecondReOpenableHashMatchIterator<IT1,IT2,OT> to matchIterator : ReusingBuildSecondReOpenableHashMatchIterator<IT1,IT2,OT> in method public reset() : void in class org.apache.flink.runtime.operators.AbstractCachedBuildSideMatchDriver |
From |
To |
|
Change Variable Type iterator : SortMergeCoGroupIterator<Record,Record> to iterator : ReusingSortMergeCoGroupIterator<Record,Record> in method public testMerge() : void in class org.apache.flink.runtime.operators.sort.ReusingSortMergeCoGroupIteratorITCase |
From |
To |
|
Change Variable Type probeSideInput : KeyGroupedIterator<IT2> to probeSideInput : ReusingKeyGroupedIterator<IT2> in method public run() : void in class org.apache.flink.runtime.operators.CoGroupWithSolutionSetFirstDriver |
From |
To |
|
Change Variable Type probeSideInput : KeyGroupedIterator<IT1> to probeSideInput : ReusingKeyGroupedIterator<IT1> in method public run() : void in class org.apache.flink.runtime.operators.CoGroupWithSolutionSetSecondDriver |
From |
To |
|
Change Variable Type iter : KeyGroupedIterator<IT> to iter : ReusingKeyGroupedIterator<IT> in method public run() : void in class org.apache.flink.runtime.operators.GroupReduceDriver |
From |
To |
|
Change Variable Type matchIterator : BuildFirstReOpenableHashMatchIterator<IT1,IT2,OT> to matchIterator : ReusingBuildFirstReOpenableHashMatchIterator<IT1,IT2,OT> in method public reset() : void in class org.apache.flink.runtime.operators.AbstractCachedBuildSideMatchDriver |
From |
To |
|
Change Variable Type groupIter : KeyGroupedIterator<Record> to groupIter : ReusingKeyGroupedIterator<Record> in method private getReducingIterator(data MutableObjectIterator<Record>, serializer TypeSerializer<Record>, comparator TypeComparator<Record>) : Iterator<Integer> in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMergerITCase |
From |
To |
|
Change Variable Type iterator : BuildFirstHashMatchIterator<IntPair,Record,Record> to iterator : ReusingBuildFirstHashMatchIterator<IntPair,Record,Record> in method public testBuildSecondWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type keyIter : KeyGroupedIterator<T> to keyIter : ReusingKeyGroupedIterator<T> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type iterator : BuildSecondHashMatchIterator<IntPair,Record,Record> to iterator : ReusingBuildSecondHashMatchIterator<IntPair,Record,Record> in method public testBuildFirstWithMixedDataTypes() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type inIter : MutableToRegularIteratorWrapper<IT> to inIter : ReusingMutableToRegularIteratorWrapper<IT> in method public run() : void in class org.apache.flink.runtime.operators.AllGroupReduceDriver |
From |
To |
|
Change Variable Type iter : KeyGroupedIteratorImmutable<IT> to iter : ReusingKeyGroupedIterator<IT> in method public run() : void in class org.apache.flink.runtime.operators.GroupReduceDriver |
From |
To |
|
Change Variable Type iterator : BuildFirstReOpenableHashMatchIterator<Record,Record,Record> to iterator : ReusingBuildFirstReOpenableHashMatchIterator<Record,Record,Record> in method private doTest(buildInput TestData.GeneratorIterator, probeInput TestData.GeneratorIterator, bgen Generator, pgen Generator) : void in class org.apache.flink.runtime.operators.hash.ReusingReOpenableHashTableITCase |
From |
To |
|
Change Variable Type iterator : BuildSecondHashMatchIterator<Record,Record,Record> to iterator : ReusingBuildSecondHashMatchIterator<Record,Record,Record> in method public testBuildSecondWithHighNumberOfCommonKeys() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type iterator : BuildFirstHashMatchIterator<Record,Record,Record> to iterator : ReusingBuildFirstHashMatchIterator<Record,Record,Record> in method public testBuildFirst() : void in class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase |
From |
To |
|
Change Variable Type values1 : KeyGroupedIterator<T1> to values1 : ReusingKeyGroupedIterator<T1> in method public callWithNextKey(matchFunction FlatJoinFunction<T1,T2,O>, collector Collector<O>) : boolean in class org.apache.flink.runtime.operators.sort.MergeMatchIterator |
From |
To |
|
Change Variable Type inIter : MutableToRegularIteratorWrapper<IT> to inIter : ReusingMutableToRegularIteratorWrapper<IT> in method public run() : void in class org.apache.flink.runtime.operators.MapPartitionDriver |
From |
To |