|
Change Variable Type reducer : GroupReduceOperatorBase<?,?,?> to reducer : ReduceOperatorBase<?,?> in method public translateDistinctPlain() : void in class org.apache.flink.api.java.operators.translation.DistinctTranslationTest |
From |
To |
|
Change Variable Type function : GroupReduceFunction<T,T> to function : ReduceFunction<T> in method protected translateToDataFlow(input Operator<T>) : SingleInputOperator<?,T,?> in class org.apache.flink.api.java.operators.DistinctOperator |
From |
To |
|
Change Variable Type reducer : GroupReduceOperatorBase<?,?,?> to reducer : ReduceOperatorBase<?,?> in method public translateDistinctPosition() : void in class org.apache.flink.api.java.operators.translation.DistinctTranslationTest |
From |
To |
|
Change Variable Type po : GroupReduceOperatorBase<T,T,GroupReduceFunction<T,T>> to po : ReduceOperatorBase<T,ReduceFunction<T>> in method protected translateToDataFlow(input Operator<T>) : SingleInputOperator<?,T,?> in class org.apache.flink.api.java.operators.DistinctOperator |
From |
To |
|
Change Variable Type reducer : GroupReduceOperatorBase<?,?,?> to reducer : ReduceOperatorBase<?,?> in method public translateDistinctExpressionKey() : void in class org.apache.flink.api.java.operators.translation.DistinctTranslationTest |
From |
To |
|
Change Variable Type reducer : GroupReduceOperatorBase<?,?,?> to reducer : ReduceOperatorBase<?,?> in method public translateDistinctPlain2() : void in class org.apache.flink.api.java.operators.translation.DistinctTranslationTest |
From |
To |
|
Change Variable Type po : PlanUnwrappingReduceGroupOperator<T,T,?> to po : SingleInputOperator<?,T,?> in method protected translateToDataFlow(input Operator<T>) : SingleInputOperator<?,T,?> in class org.apache.flink.api.java.operators.DistinctOperator |
From |
To |