|
Merge Parameter [input1 : MutableObjectIterator<T1>, serializer1 : TypeSerializer<T1>] to input2 : MutableObjectIterator<T2> in method public NonReusingSortMergeCoGroupIterator(input1 MutableObjectIterator<T1>, input2 MutableObjectIterator<T2>, serializer1 TypeSerializer<T1>, groupingComparator1 TypeComparator<T1>, serializer2 TypeSerializer<T2>, groupingComparator2 TypeComparator<T2>, pairComparator TypePairComparator<T1,T2>) in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIterator |
From |
To |
|
Merge Parameter [input2 : MutableObjectIterator<T2>, serializer2 : TypeSerializer<T2>] to input1 : MutableObjectIterator<T1> in method public NonReusingSortMergeCoGroupIterator(input1 MutableObjectIterator<T1>, input2 MutableObjectIterator<T2>, serializer1 TypeSerializer<T1>, groupingComparator1 TypeComparator<T1>, serializer2 TypeSerializer<T2>, groupingComparator2 TypeComparator<T2>, pairComparator TypePairComparator<T1,T2>) in class org.apache.flink.runtime.operators.sort.NonReusingSortMergeCoGroupIterator |
From |
To |