|
Rename Method public testJoinOnATupleInputWithKeyFieldSelectorAndACustomTypeInputWithKeyExtractor() : void renamed to public testJoinWithMixedKeyTypes2() : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method public testUDFJoinOnTuplesWithMultipleKeyFieldPositions() : void renamed to public testJoinOnTuplesWithCompositeKeyPositions() : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method public testSelectingMultipleFieldsUsingExpressionLanguage() : void renamed to public testJoinWithCompositeKeyExpressions() : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method public testUDFJoinOnTuplesWithTupleReturningKeySelectors() : void renamed to public testJoinWithTupleReturningKeySelectors() : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method public testUDFLeftOuterJoinOnTuplesWithKeyFieldPositions() : void renamed to private testLeftOuterJoinOnTuplesWithKeyPositions(hint JoinHint) : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method public testJoinOnACustomTypeInputWithKeyExtractorAndATupleInputWithKeyFieldSelector() : void renamed to public testJoinWithMixedKeyTypes1() : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method package matchTupleIntPairValues(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> renamed to public joinIntPairs(leftMap Map<Integer,Collection<Integer>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleIntPairMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashJoinIteratorITCase |
From |
To |
|
Rename Method public testUDFRightOuterJoinOnTuplesWithKeyFieldPositions() : void renamed to private testRightOuterJoinOnTuplesWithKeyPositions(hint JoinHint) : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method package matchSecondTupleFields(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> renamed to public joinTuples(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>) : Map<Integer,Collection<TupleMatch>> in class org.apache.flink.runtime.operators.hash.NonReusingHashJoinIteratorITCase |
From |
To |
|
Rename Method public testJoinNestedPojoAgainstTupleSelectedUsingInteger() : void renamed to public testJoinWithNestedKeyExpression2() : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method public testUDFFullOuterJoinOnTuplesWithKeyFieldPositions() : void renamed to private testFullOuterJoinOnTuplesWithKeyPositions(hint JoinHint) : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Rename Method public testJoinNestedPojoAgainstTupleSelectedUsingString() : void renamed to public testJoinWithNestedKeyExpression1() : void in class org.apache.flink.test.javaApiOperators.OuterJoinITCase |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.FullOuterJoinDriver |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.RightOuterJoinDriver |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected abstract getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.AbstractOuterJoinDriver |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.FullOuterJoinDriver |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected abstract getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.AbstractOuterJoinDriver |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.LeftOuterJoinDriver |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.LeftOuterJoinDriver |
From |
To |
|
Change Parameter Type numPages : int to driverMemFraction : double in method protected getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.RightOuterJoinDriver |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.NonReusingBuildFirstReOpenableHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.NonReusingBuildFirstReOpenableHashJoinIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.HashMatchIteratorBase renamed to org.apache.flink.runtime.operators.hash.HashJoinIteratorBase |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.NonReusingHashMatchIteratorITCase renamed to org.apache.flink.runtime.operators.hash.NonReusingHashJoinIteratorITCase |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.ReusingHashMatchIteratorITCase renamed to org.apache.flink.runtime.operators.hash.ReusingHashJoinIteratorITCase |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.ReusingBuildSecondHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildSecondHashJoinIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.NonReusingBuildSecondReOpenableHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.NonReusingBuildSecondReOpenableHashJoinIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.ReusingBuildFirstHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildFirstHashJoinIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.ReusingBuildFirstReOpenableHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildFirstReOpenableHashJoinIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashJoinIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.ReusingBuildSecondReOpenableHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.ReusingBuildSecondReOpenableHashJoinIterator |
From |
To |
|
Rename Class org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashMatchIterator renamed to org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashJoinIterator |
From |
To |
|
Change Variable Type matchIterator : ReusingBuildFirstReOpenableHashMatchIterator<IT1,IT2,OT> to matchIterator : ReusingBuildFirstReOpenableHashJoinIterator<IT1,IT2,OT> in method public reset() : void in class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver |
From |
To |
|
Change Variable Type matchIterator : ReusingBuildSecondReOpenableHashMatchIterator<IT1,IT2,OT> to matchIterator : ReusingBuildSecondReOpenableHashJoinIterator<IT1,IT2,OT> in method public reset() : void in class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver |
From |
To |
|
Change Variable Type matchIterator : NonReusingBuildFirstReOpenableHashMatchIterator<IT1,IT2,OT> to matchIterator : NonReusingBuildFirstReOpenableHashJoinIterator<IT1,IT2,OT> in method public reset() : void in class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver |
From |
To |
|
Change Variable Type matchIterator : NonReusingBuildSecondReOpenableHashMatchIterator<IT1,IT2,OT> to matchIterator : NonReusingBuildSecondReOpenableHashJoinIterator<IT1,IT2,OT> in method public reset() : void in class org.apache.flink.runtime.operators.AbstractCachedBuildSideJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.LeftOuterJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.LeftOuterJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.RightOuterJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.FullOuterJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.RightOuterJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.FullOuterJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected abstract getNonReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.AbstractOuterJoinDriver |
From |
To |
|
Rename Parameter numPages : int to driverMemFraction : double in method protected abstract getReusingOuterJoinIterator(driverStrategy DriverStrategy, in1 MutableObjectIterator<IT1>, in2 MutableObjectIterator<IT2>, serializer1 TypeSerializer<IT1>, comparator1 TypeComparator<IT1>, serializer2 TypeSerializer<IT2>, comparator2 TypeComparator<IT2>, pairComparatorFactory TypePairComparatorFactory<IT1,IT2>, memoryManager MemoryManager, ioManager IOManager, driverMemFraction double) : JoinTaskIterator<IT1,IT2,OT> in class org.apache.flink.runtime.operators.AbstractOuterJoinDriver |
From |
To |