|
Change Parameter Type rawKeys1 : Keys.SelectorFunctionKeys<I1,?> to rawKeys1 : SelectorFunctionKeys<I1,?> in method private translateSelectorFunctionCoGroupLeft(rawKeys1 SelectorFunctionKeys<I1,?>, logicalKeyPositions2 int[], function CoGroupFunction<I1,I2,OUT>, inputType2 TypeInformation<I2>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Parameter Type rawKeys2 : Keys.SelectorFunctionKeys<I2,?> to rawKeys2 : SelectorFunctionKeys<I2,?> in method private translateSelectorFunctionCoGroupRight(logicalKeyPositions1 int[], rawKeys2 SelectorFunctionKeys<I2,?>, function CoGroupFunction<I1,I2,OUT>, inputType1 TypeInformation<I1>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Rename Variable noop : PartitionOperatorBase<T> to partitionedInput : PartitionOperatorBase<T> in method protected translateToDataFlow(input Operator<T>) : SingleInputOperator<?,T,?> in class org.apache.flink.api.java.operators.PartitionOperator |
From |
To |
|
Rename Variable noop : PartitionOperatorBase<T> to rebalancedInput : PartitionOperatorBase<T> in method protected translateToDataFlow(input Operator<T>) : SingleInputOperator<?,T,?> in class org.apache.flink.api.java.operators.PartitionOperator |
From |
To |
|
Rename Variable keyMapper2 : MapOperatorBase<I2,Tuple2<K,I2>,MapFunction<I2,Tuple2<K,I2>>> to keyedInput2 : Operator<Tuple2<K,I2>> in method private translateSelectorFunctionCoGroupRight(logicalKeyPositions1 int[], rawKeys2 SelectorFunctionKeys<I2,?>, function CoGroupFunction<I1,I2,OUT>, inputType1 TypeInformation<I1>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Rename Variable keyMapper1 : MapOperatorBase<I1,Tuple2<K,I1>,MapFunction<I1,Tuple2<K,I1>>> to keyedInput1 : Operator<Tuple2<K,I1>> in method private translateSelectorFunctionCoGroupLeft(rawKeys1 SelectorFunctionKeys<I1,?>, logicalKeyPositions2 int[], function CoGroupFunction<I1,I2,OUT>, inputType2 TypeInformation<I2>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Variable Type selectorKeys : Keys.SelectorFunctionKeys<IN,?> to selectorKeys : SelectorFunctionKeys<IN,?> in method protected translateToDataFlow(input Operator<IN>) : SingleInputOperator<?,IN,?> in class org.apache.flink.api.java.operators.ReduceOperator |
From |
To |
|
Change Variable Type selectorKeys1 : Keys.SelectorFunctionKeys<I1,?> to selectorKeys1 : SelectorFunctionKeys<I1,?> in method protected translateToDataFlow(input1 Operator<I1>, input2 Operator<I2>) : JoinOperatorBase<?,?,OUT,?> in class org.apache.flink.api.java.operators.JoinOperator.EquiJoin |
From |
To |
|
Change Variable Type selectorKeys2 : Keys.SelectorFunctionKeys<I2,?> to selectorKeys2 : SelectorFunctionKeys<I2,?> in method protected translateToDataFlow(input1 Operator<I1>, input2 Operator<I2>) : CoGroupOperatorBase<?,?,OUT,?> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Variable Type selectorKeys1 : Keys.SelectorFunctionKeys<I1,?> to selectorKeys1 : SelectorFunctionKeys<I1,?> in method protected translateToDataFlow(input1 Operator<I1>, input2 Operator<I2>) : CoGroupOperatorBase<?,?,OUT,?> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Variable Type selectorKeys : Keys.SelectorFunctionKeys<IN,?> to selectorKeys : SelectorFunctionKeys<IN,?> in method protected translateToDataFlow(input Operator<IN>) : GroupReduceOperatorBase<?,OUT,?> in class org.apache.flink.api.java.operators.GroupReduceOperator |
From |
To |
|
Change Variable Type keys2 : Keys.SelectorFunctionKeys<I2,K> to keys2 : SelectorFunctionKeys<I2,K> in method private translateSelectorFunctionCoGroupRight(logicalKeyPositions1 int[], rawKeys2 SelectorFunctionKeys<I2,?>, function CoGroupFunction<I1,I2,OUT>, inputType1 TypeInformation<I1>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Variable Type selectorKeys : Keys.SelectorFunctionKeys<T,?> to selectorKeys : SelectorFunctionKeys<T,?> in method protected translateToDataFlow(input Operator<T>) : GroupReduceOperatorBase<?,T,?> in class org.apache.flink.api.java.operators.DistinctOperator |
From |
To |
|
Change Variable Type po : MapOperatorBase<?,IN,?> to po : SingleInputOperator<?,IN,?> in method protected translateToDataFlow(input Operator<IN>) : SingleInputOperator<?,IN,?> in class org.apache.flink.api.java.operators.ReduceOperator |
From |
To |
|
Change Variable Type fieldType : TypeInformation to fieldType : TypeInformation<?> in method public ExpressionKeys(groupingFields int[], type TypeInformation<T>, allowEmpty boolean) in class org.apache.flink.api.java.operators.Keys.ExpressionKeys |
From |
To |
|
Change Variable Type keys1 : Keys.SelectorFunctionKeys<I1,K> to keys1 : SelectorFunctionKeys<I1,K> in method private translateSelectorFunctionCoGroupLeft(rawKeys1 SelectorFunctionKeys<I1,?>, logicalKeyPositions2 int[], function CoGroupFunction<I1,I2,OUT>, inputType2 TypeInformation<I2>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Variable Type keyMapper2 : MapOperatorBase<I2,Tuple2<K,I2>,MapFunction<I2,Tuple2<K,I2>>> to keyedInput2 : Operator<Tuple2<K,I2>> in method private translateSelectorFunctionCoGroupRight(logicalKeyPositions1 int[], rawKeys2 SelectorFunctionKeys<I2,?>, function CoGroupFunction<I1,I2,OUT>, inputType1 TypeInformation<I1>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Variable Type keyMapper1 : MapOperatorBase<I1,Tuple2<K,I1>,MapFunction<I1,Tuple2<K,I1>>> to keyedInput1 : Operator<Tuple2<K,I1>> in method private translateSelectorFunctionCoGroupLeft(rawKeys1 SelectorFunctionKeys<I1,?>, logicalKeyPositions2 int[], function CoGroupFunction<I1,I2,OUT>, inputType2 TypeInformation<I2>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator |
From |
To |
|
Change Variable Type selectorKeys : Keys.SelectorFunctionKeys<IN,?> to selectorKeys : SelectorFunctionKeys<IN,?> in method protected translateToDataFlow(input Operator<IN>) : GroupCombineOperatorBase<?,OUT,?> in class org.apache.flink.api.java.operators.GroupCombineOperator |
From |
To |
|
Change Variable Type selectorKeys2 : Keys.SelectorFunctionKeys<I2,?> to selectorKeys2 : SelectorFunctionKeys<I2,?> in method protected translateToDataFlow(input1 Operator<I1>, input2 Operator<I2>) : JoinOperatorBase<?,?,OUT,?> in class org.apache.flink.api.java.operators.JoinOperator.EquiJoin |
From |
To |
|
Extract And Move Method public createTypeWithKey(key SelectorFunctionKeys<T,K>) : TypeInformation<Tuple2<K,T>> extracted from private translateSelectorFunctionCoGroupRight(logicalKeyPositions1 int[], rawKeys2 Keys.SelectorFunctionKeys<I2,?>, function CoGroupFunction<I1,I2,OUT>, inputType1 TypeInformation<I1>, inputType2 TypeInformation<I2>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator & moved to class org.apache.flink.api.java.operators.Keys.SelectorFunctionKeys |
From |
To |
|
Extract And Move Method protected getGroupOrdering() : Ordering extracted from protected translateToDataFlow(input Operator<IN>) : GroupCombineOperatorBase<?,OUT,?> in class org.apache.flink.api.java.operators.GroupCombineOperator & moved to class org.apache.flink.api.java.operators.SortedGrouping |
From |
To |
|
Extract And Move Method public createTypeWithKey(key SelectorFunctionKeys<T,K>) : TypeInformation<Tuple2<K,T>> extracted from private translateSelectorFunctionCoGroupLeft(rawKeys1 Keys.SelectorFunctionKeys<I1,?>, logicalKeyPositions2 int[], function CoGroupFunction<I1,I2,OUT>, inputType1 TypeInformation<I1>, inputType2 TypeInformation<I2>, outputType TypeInformation<OUT>, name String, input1 Operator<I1>, input2 Operator<I2>) : PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K> in class org.apache.flink.api.java.operators.CoGroupOperator & moved to class org.apache.flink.api.java.operators.Keys.SelectorFunctionKeys |
From |
To |
|
Extract And Move Method protected getGroupOrdering() : Ordering extracted from protected translateToDataFlow(input Operator<IN>) : GroupReduceOperatorBase<?,OUT,?> in class org.apache.flink.api.java.operators.GroupReduceOperator & moved to class org.apache.flink.api.java.operators.SortedGrouping |
From |
To |