|
Change Parameter Type context : PactTaskContext<FlatCombineFunction<T>,T> to context : PactTaskContext<FlatCombineFunction<IN,OUT>,OUT> in method public setup(context PactTaskContext<FlatCombineFunction<IN,OUT>,OUT>) : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Parameter Type combineStub : FlatCombineFunction<E> to combineStub : FlatCombineFunction<E,E> in method public CombiningUnilateralSortMerger(combineStub FlatCombineFunction<E,E>, memoryManager MemoryManager, ioManager IOManager, input MutableObjectIterator<E>, parentTask AbstractInvokable, serializerFactory TypeSerializerFactory<E>, comparator TypeComparator<E>, memoryFraction double, numSortBuffers int, maxNumFileHandles int, startSpillingFraction float) in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger |
From |
To |
|
Change Parameter Type combineStub : FlatCombineFunction<E> to combineStub : FlatCombineFunction<E,E> in method public CombiningUnilateralSortMerger(combineStub FlatCombineFunction<E,E>, memoryManager MemoryManager, ioManager IOManager, input MutableObjectIterator<E>, parentTask AbstractInvokable, serializerFactory TypeSerializerFactory<E>, comparator TypeComparator<E>, memoryFraction double, maxNumFileHandles int, startSpillingFraction float) in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger |
From |
To |
|
Change Parameter Type record : T to record : IN in method public collect(record IN) : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type combineStub : FlatCombineFunction<E> to combineStub : FlatCombineFunction<E,E> in method public go() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger.CombiningSpillingThread |
From |
To |
|
Change Variable Type in : MutableObjectIterator<T> to in : MutableObjectIterator<IN> in method public run() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type combiner : FlatCombineFunction<T> to combiner : FlatCombineFunction<IN,OUT> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type serializerFactory : TypeSerializerFactory<T> to serializerFactory : TypeSerializerFactory<IN> in method public prepare() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type groupingComparatorFactory : TypeComparatorFactory<T> to groupingComparatorFactory : TypeComparatorFactory<IN> in method public openTask() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type sorter : InMemorySorter<T> to sorter : InMemorySorter<IN> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type keyIter : ReusingKeyGroupedIterator<T> to keyIter : ReusingKeyGroupedIterator<IN> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type sortingComparatorFactory : TypeComparatorFactory<T> to sortingComparatorFactory : TypeComparatorFactory<IN> in method public openTask() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type output : Collector<T> to output : Collector<OUT> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type clazz : Class<FlatCombineFunction<T>> to clazz : Class<FlatCombineFunction<IN,OUT>> in method public getStubType() : Class<FlatCombineFunction<IN,OUT>> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type keyIter : NonReusingKeyGroupedIterator<T> to keyIter : NonReusingKeyGroupedIterator<IN> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type testTask : GroupReduceCombineDriver<Record> to testTask : GroupReduceCombineDriver<Record,Record> in method public testSingleLevelMergeCombineTask() : void in class org.apache.flink.runtime.operators.CombineTaskExternalITCase |
From |
To |
|
Change Variable Type stub : FlatCombineFunction<T> to stub : FlatCombineFunction<IN,OUT> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type testTask : GroupReduceCombineDriver<Record> to testTask : GroupReduceCombineDriver<Record,Record> in method public testCombineTask() : void in class org.apache.flink.runtime.operators.CombineTaskTest |
From |
To |
|
Change Variable Type combiner : FlatCombineFunction<T> to combiner : FlatCombineFunction<IN,OUT> in method public setup(parent AbstractInvokable) : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type sorter : InMemorySorter<T> to sorter : InMemorySorter<IN> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type output : Collector<T> to output : Collector<OUT> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type combineStub : FlatCombineFunction<E> to combineStub : FlatCombineFunction<E,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 keyIter : ReusingKeyGroupedIterator<T> to keyIter : ReusingKeyGroupedIterator<IN> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type testTask : GroupReduceCombineDriver<Record> to testTask : GroupReduceCombineDriver<Record,Record> in method public testFailingCombineTask() : void in class org.apache.flink.runtime.operators.CombineTaskTest |
From |
To |
|
Change Variable Type keyIter : NonReusingKeyGroupedIterator<T> to keyIter : NonReusingKeyGroupedIterator<IN> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type testTask : GroupReduceCombineDriver<Record> to testTask : GroupReduceCombineDriver<Record,Record> in method public testCancelCombineTaskSorting() : void in class org.apache.flink.runtime.operators.CombineTaskTest |
From |
To |
|
Change Variable Type value : T to value : IN in method public run() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type serializer : TypeSerializer<T> to serializer : TypeSerializer<IN> in method public run() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type testTask : GroupReduceCombineDriver<Record> to testTask : GroupReduceCombineDriver<Record,Record> in method public testMultiLevelMergeCombineTask() : void in class org.apache.flink.runtime.operators.CombineTaskExternalITCase |
From |
To |
|
Change Variable Type serializerFactory : TypeSerializerFactory<T> to serializerFactory : TypeSerializerFactory<IN> in method public openTask() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type combiner : FlatCombineFunction<IT> to combiner : FlatCombineFunction<IT,OT> in method public run() : void in class org.apache.flink.runtime.operators.AllGroupReduceDriver |
From |
To |
|
Change Variable Type output : Collector<IT> to output : Collector<OT> in method public run() : void in class org.apache.flink.runtime.operators.AllGroupReduceDriver |
From |
To |
|
Change Attribute Type serializer : TypeSerializer<T> to serializer : TypeSerializer<IN> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Attribute Type serializer : TypeSerializer<T> to serializer : TypeSerializer<IN> in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Attribute Type sortingComparator : TypeComparator<T> to sortingComparator : TypeComparator<IN> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Attribute Type sortingComparator : TypeComparator<T> to sortingComparator : TypeComparator<IN> in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Attribute Type combiner : FlatCombineFunction<T> to combiner : FlatCombineFunction<IN,OUT> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Attribute Type combiner : FlatCombineFunction<T> to combiner : FlatCombineFunction<IN,OUT> in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Attribute Type sorter : InMemorySorter<T> to sorter : InMemorySorter<IN> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Attribute Type output : Collector<T> to output : Collector<OUT> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Attribute Type sorter : InMemorySorter<T> to sorter : InMemorySorter<IN> in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Attribute Type combineStub : FlatCombineFunction<E> to combineStub : FlatCombineFunction<E,E> in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger |
From |
To |
|
Change Attribute Type groupingComparator : TypeComparator<T> to groupingComparator : TypeComparator<IN> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Attribute Type groupingComparator : TypeComparator<T> to groupingComparator : TypeComparator<IN> in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Attribute Type taskContext : PactTaskContext<FlatCombineFunction<T>,T> to taskContext : PactTaskContext<FlatCombineFunction<IN,OUT>,OUT> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |