|
Change Parameter Type function : FlatCombineFunction<IN,OUT> to function : GroupCombineFunction<IN,OUT> in method public GroupCombineOperator(input Grouping<IN>, resultType TypeInformation<OUT>, function GroupCombineFunction<IN,OUT>, defaultName String) in class org.apache.flink.api.java.operators.GroupCombineOperator |
From |
To |
|
Change Parameter Type combineInterface : FlatCombineFunction<IN,OUT> to combineInterface : GroupCombineFunction<IN,OUT> in method public getGroupCombineReturnTypes(combineInterface GroupCombineFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor |
From |
To |
|
Change Parameter Type function : FlatCombineFunction<IN,OUT> to function : GroupCombineFunction<IN,OUT> in method public GroupCombineOperator(input DataSet<IN>, resultType TypeInformation<OUT>, function GroupCombineFunction<IN,OUT>, defaultName String) in class org.apache.flink.api.java.operators.GroupCombineOperator |
From |
To |
|
Change Parameter Type wrapped : FlatCombineFunction<IN,OUT> to wrapped : GroupCombineFunction<IN,OUT> in method private TupleUnwrappingGroupCombiner(wrapped GroupCombineFunction<IN,OUT>) in class org.apache.flink.api.java.operators.translation.PlanUnwrappingGroupCombineOperator.TupleUnwrappingGroupCombiner |
From |
To |
|
Change Parameter Type context : PactTaskContext<FlatCombineFunction<IN,OUT>,OUT> to context : PactTaskContext<GroupCombineFunction<IN,OUT>,OUT> in method public setup(context PactTaskContext<GroupCombineFunction<IN,OUT>,OUT>) : void in class org.apache.flink.runtime.operators.AllGroupCombineDriver |
From |
To |
|
Change Parameter Type udf : FlatCombineFunction<IN,OUT> to udf : GroupCombineFunction<IN,OUT> in method public PlanUnwrappingSortedGroupCombineOperator(udf GroupCombineFunction<IN,OUT>, groupingKey Keys.SelectorFunctionKeys<IN,K1>, sortingKey Keys.SelectorFunctionKeys<IN,K2>, name String, outType TypeInformation<OUT>, typeInfoWithKey TypeInformation<Tuple3<K1,K2,IN>>) in class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedGroupCombineOperator |
From |
To |
|
Change Parameter Type wrapped : FlatCombineFunction<IN,OUT> to wrapped : GroupCombineFunction<IN,OUT> in method private TupleUnwrappingGroupReducer(wrapped GroupCombineFunction<IN,OUT>) in class org.apache.flink.api.java.operators.translation.PlanUnwrappingSortedGroupCombineOperator.TupleUnwrappingGroupReducer |
From |
To |
|
Change Parameter Type context : PactTaskContext<FlatCombineFunction<IN,OUT>,OUT> to context : PactTaskContext<GroupCombineFunction<IN,OUT>,OUT> in method public setup(context PactTaskContext<GroupCombineFunction<IN,OUT>,OUT>) : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Parameter Type combineStub : FlatCombineFunction<E,E> to combineStub : GroupCombineFunction<E,E> in method public CombiningUnilateralSortMerger(combineStub GroupCombineFunction<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 combiner : FlatCombineFunction<T,R> to combiner : GroupCombineFunction<T,R> in method public combineGroup(combiner GroupCombineFunction<T,R>) : GroupCombineOperator<T,R> in class org.apache.flink.api.java.operators.SortedGrouping |
From |
To |
|
Change Parameter Type combiner : FlatCombineFunction<T,R> to combiner : GroupCombineFunction<T,R> in method public combineGroup(combiner GroupCombineFunction<T,R>) : GroupCombineOperator<T,R> in class org.apache.flink.api.java.DataSet |
From |
To |
|
Change Parameter Type combineInterface : FlatCombineFunction<IN,OUT> to combineInterface : GroupCombineFunction<IN,OUT> in method public getGroupCombineReturnTypes(combineInterface GroupCombineFunction<IN,OUT>, inType TypeInformation<IN>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor |
From |
To |
|
Change Parameter Type function : FlatCombineFunction<IN,OUT> to function : GroupCombineFunction<IN,OUT> in method private translateSelectorFunctionSortedReducer(rawGroupingKey Keys.SelectorFunctionKeys<IN,?>, rawSortingKey Keys.SelectorFunctionKeys<IN,?>, function GroupCombineFunction<IN,OUT>, inputType TypeInformation<IN>, outputType TypeInformation<OUT>, name String, input Operator<IN>) : PlanUnwrappingSortedGroupCombineOperator<IN,OUT,K1,K2> in class org.apache.flink.api.java.operators.GroupCombineOperator |
From |
To |
|
Change Parameter Type combiner : FlatCombineFunction<T,R> to combiner : GroupCombineFunction<T,R> in method public combineGroup(combiner GroupCombineFunction<T,R>) : GroupCombineOperator<T,R> in class org.apache.flink.api.java.operators.UnsortedGrouping |
From |
To |
|
Change Parameter Type combineStub : FlatCombineFunction<E,E> to combineStub : GroupCombineFunction<E,E> in method public CombiningUnilateralSortMerger(combineStub GroupCombineFunction<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 function : FlatCombineFunction<IN,OUT> to function : GroupCombineFunction<IN,OUT> in method private translateSelectorFunctionReducer(rawKeys Keys.SelectorFunctionKeys<IN,?>, function GroupCombineFunction<IN,OUT>, inputType TypeInformation<IN>, outputType TypeInformation<OUT>, name String, input Operator<IN>) : PlanUnwrappingGroupCombineOperator<IN,OUT,K> in class org.apache.flink.api.java.operators.GroupCombineOperator |
From |
To |
|
Change Parameter Type udf : FlatCombineFunction<IN,OUT> to udf : GroupCombineFunction<IN,OUT> in method public PlanUnwrappingGroupCombineOperator(udf GroupCombineFunction<IN,OUT>, key Keys.SelectorFunctionKeys<IN,K>, name String, outType TypeInformation<OUT>, typeInfoWithKey TypeInformation<Tuple2<K,IN>>) in class org.apache.flink.api.java.operators.translation.PlanUnwrappingGroupCombineOperator |
From |
To |
|
Change Variable Type reducer : FlatCombineFunction<IN,OUT> to reducer : GroupCombineFunction<IN,OUT> in method public run() : void in class org.apache.flink.runtime.operators.AllGroupCombineDriver |
From |
To |
|
Change Variable Type function : FlatCombineFunction<IN,OUT> to function : GroupCombineFunction<IN,OUT> in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.GroupCombineOperatorBase |
From |
To |
|
Change Variable Type clazz : Class<FlatCombineFunction<IN,OUT>> to clazz : Class<GroupCombineFunction<IN,OUT>> in method public getStubType() : Class<GroupCombineFunction<IN,OUT>> in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type clazz : Class<FlatCombineFunction<IN,OUT>> to clazz : Class<GroupCombineFunction<IN,OUT>> in method public getStubType() : Class<GroupCombineFunction<IN,OUT>> in class org.apache.flink.runtime.operators.AllGroupCombineDriver |
From |
To |
|
Change Variable Type combiner : FlatCombineFunction<IT,OT> to combiner : GroupCombineFunction<IT,OT> in method public run() : void in class org.apache.flink.runtime.operators.AllGroupReduceDriver |
From |
To |
|
Change Variable Type combiner : FlatCombineFunction<IN,OUT> to combiner : GroupCombineFunction<IN,OUT> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.GroupReduceCombineDriver |
From |
To |
|
Change Variable Type combiner : FlatCombineFunction<IN,OUT> to combiner : GroupCombineFunction<IN,OUT> in method public setup(parent AbstractInvokable) : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |
|
Change Variable Type po : GroupCombineOperatorBase<IN,OUT,FlatCombineFunction<IN,OUT>> to po : GroupCombineOperatorBase<IN,OUT,GroupCombineFunction<IN,OUT>> in method protected translateToDataFlow(input Operator<IN>) : GroupCombineOperatorBase<?,OUT,?> in class org.apache.flink.api.java.operators.GroupCombineOperator |
From |
To |
|
Change Variable Type combineStub : FlatCombineFunction<E,E> to combineStub : GroupCombineFunction<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 combineStub : FlatCombineFunction<E,E> to combineStub : GroupCombineFunction<E,E> in method public go() : void in class org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger.CombiningSpillingThread |
From |
To |
|
Change Variable Type stub : FlatCombineFunction<IN,OUT> to stub : GroupCombineFunction<IN,OUT> in method private sortAndCombine() : void in class org.apache.flink.runtime.operators.chaining.SynchronousChainedCombineDriver |
From |
To |