|
Change Parameter Type joinOperatorBase : JoinOperatorBase<?,?,?,?> to operator : OuterJoinOperatorBase<?,?,?,?> in method public OuterJoinNode(operator OuterJoinOperatorBase<?,?,?,?>) in class org.apache.flink.optimizer.dag.OuterJoinNode |
From |
To |
|
Change Parameter Type joinOperatorBase : JoinOperatorBase<?,?,?,?> to joinOperatorBase : InnerJoinOperatorBase<?,?,?,?> in method private getDataProperties(joinOperatorBase InnerJoinOperatorBase<?,?,?,?>, joinHint JoinHint, customPartitioner Partitioner<?>) : List<OperatorDescriptorDual> in class org.apache.flink.optimizer.dag.JoinNode |
From |
To |
|
Change Parameter Type joinOperatorBase : JoinOperatorBase<?,?,?,?> to joinOperatorBase : InnerJoinOperatorBase<?,?,?,?> in method public JoinNode(joinOperatorBase InnerJoinOperatorBase<?,?,?,?>) in class org.apache.flink.optimizer.dag.JoinNode |
From |
To |
|
Change Return Type DefaultJoin<I1,I2> to JoinFunctionAssigner<I1,I2> in method public equalTo(fields int...) : JoinFunctionAssigner<I1,I2> in class org.apache.flink.api.java.operators.join.JoinOperatorSets.JoinOperatorSetsPredicate |
From |
To |
|
Change Return Type DefaultJoin<I1,I2> to JoinFunctionAssigner<I1,I2> in method public equalTo(keySelector KeySelector<I2,K>) : JoinFunctionAssigner<I1,I2> in class org.apache.flink.api.java.operators.join.JoinOperatorSets.JoinOperatorSetsPredicate |
From |
To |
|
Change Return Type JoinOperatorSets<T,R> to InnerJoinOperatorSets<T,R> in method public join(other DataSet<R>, strategy JoinHint) : InnerJoinOperatorSets<T,R> in class org.apache.flink.api.java.DataSet |
From |
To |
|
Change Return Type JoinOperatorBase<?,?,?,?> to OuterJoinOperatorBase<?,?,?,?> in method public getOperator() : OuterJoinOperatorBase<?,?,?,?> in class org.apache.flink.optimizer.dag.OuterJoinNode |
From |
To |
|
Change Return Type DefaultJoin<I1,I2> to JoinFunctionAssigner<I1,I2> in method public equalTo(fields String...) : JoinFunctionAssigner<I1,I2> in class org.apache.flink.api.java.operators.join.JoinOperatorSets.JoinOperatorSetsPredicate |
From |
To |
|
Change Return Type JoinOperatorSets<T,R> to InnerJoinOperatorSets<T,R> in method public joinWithTiny(other DataSet<R>) : InnerJoinOperatorSets<T,R> in class org.apache.flink.api.java.DataSet |
From |
To |
|
Change Return Type JoinOperatorSets<T,R> to InnerJoinOperatorSets<T,R> in method public joinWithHuge(other DataSet<R>) : InnerJoinOperatorSets<T,R> in class org.apache.flink.api.java.DataSet |
From |
To |
|
Change Return Type JoinOperatorSets<T,R> to InnerJoinOperatorSets<T,R> in method public join(other DataSet<R>) : InnerJoinOperatorSets<T,R> in class org.apache.flink.api.java.DataSet |
From |
To |
|
Change Return Type JoinOperatorBase<?,?,?,?> to InnerJoinOperatorBase<?,?,?,?> in method public getOperator() : InnerJoinOperatorBase<?,?,?,?> in class org.apache.flink.optimizer.dag.JoinNode |
From |
To |
|
Change Variable Type base : JoinOperatorBase<String,String,Integer,RichFlatJoinFunction<String,String,Integer>> to base : InnerJoinOperatorBase<String,String,Integer,RichFlatJoinFunction<String,String,Integer>> in method public testJoinRich() : void in class org.apache.flink.api.common.operators.base.InnerJoinOperatorBaseTest |
From |
To |
|
Change Variable Type projectJoinOperator : JoinOperatorBase<?,?,?,?> to projectJoinOperator : InnerJoinOperatorBase<?,?,?,?> in method public testJoinProjectionSemProps2() : void in class org.apache.flink.api.java.functions.SemanticPropertiesProjectionTest |
From |
To |
|
Change Variable Type base : JoinOperatorBase<String,String,Integer,FlatJoinFunction<String,String,Integer>> to base : InnerJoinOperatorBase<String,String,Integer,FlatJoinFunction<String,String,Integer>> in method public testJoinPlain() : void in class org.apache.flink.api.common.operators.base.InnerJoinOperatorBaseTest |
From |
To |
|
Change Variable Type descr : SortMergeJoinDescriptor to descr : SortMergeInnerJoinDescriptor in method public checkInompatiblePartitionings() : void in class org.apache.flink.optimizer.operators.JoinGlobalPropertiesCompatibilityTest |
From |
To |
|
Change Variable Type solutionSetJoin : JoinOperatorBase<?,?,?,?> to solutionSetJoin : InnerJoinOperatorBase<?,?,?,?> in method public testCorrectTranslation() : void in class org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest |
From |
To |
|
Change Variable Type join : JoinOperatorBase<?,?,?,?> to join : InnerJoinOperatorBase<?,?,?,?> in method public testBinaryForwardedInLine1() : void in class org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest |
From |
To |
|
Change Variable Type translated : JoinOperatorBase<?,?,OUT,?> to builder : JoinOperatorBaseBuilder<OUT> 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 join : JoinOperatorBase<?,?,?,?> to join : InnerJoinOperatorBase<?,?,?,?> in method public testBinaryForwardedInLine2() : void in class org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest |
From |
To |
|
Change Variable Type join : JoinOperatorBase<?,?,?,?> to join : InnerJoinOperatorBase<?,?,?,?> in method public testBinaryReadFieldsAnnotation() : void in class org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest |
From |
To |
|
Change Variable Type base : JoinOperatorBase<Tuple3<String,Double,Integer>,Tuple2<Integer,String>,Tuple2<Double,String>,FlatJoinFunction<Tuple3<String,Double,Integer>,Tuple2<Integer,String>,Tuple2<Double,String>>> to base : InnerJoinOperatorBase<Tuple3<String,Double,Integer>,Tuple2<Integer,String>,Tuple2<Double,String>,FlatJoinFunction<Tuple3<String,Double,Integer>,Tuple2<Integer,String>,Tuple2<Double,String>>> in method public testTupleBaseJoiner() : void in class org.apache.flink.api.common.operators.base.InnerJoinOperatorBaseTest |
From |
To |
|
Change Variable Type join : JoinOperatorBase<?,?,?,?> to join : InnerJoinOperatorBase<?,?,?,?> in method public testBinaryForwardedAnnotationInLineMixed1() : void in class org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest |
From |
To |
|
Change Variable Type join : JoinOperatorBase<?,?,?,?> to join : InnerJoinOperatorBase<?,?,?,?> in method public testBinaryForwardedAnnotation() : void in class org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest |
From |
To |
|
Change Variable Type join : JoinOperatorBase<?,?,?,?> to join : InnerJoinOperatorBase<?,?,?,?> in method public testBinaryForwardedAnnotationInLineMixed2() : void in class org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest |
From |
To |
|
Change Variable Type descr : SortMergeJoinDescriptor to descr : SortMergeInnerJoinDescriptor in method public checkCompatiblePartitionings() : void in class org.apache.flink.optimizer.operators.JoinGlobalPropertiesCompatibilityTest |
From |
To |
|
Change Variable Type projectJoinOperator : JoinOperatorBase<?,?,?,?> to projectJoinOperator : InnerJoinOperatorBase<?,?,?,?> in method public testJoinProjectionSemProps1() : void in class org.apache.flink.api.java.functions.SemanticPropertiesProjectionTest |
From |
To |
|
Change Variable Type worksetSelfJoin : JoinOperatorBase<?,?,?,?> to worksetSelfJoin : InnerJoinOperatorBase<?,?,?,?> in method public testCorrectTranslation() : void in class org.apache.flink.api.java.operators.translation.DeltaIterationTranslationTest |
From |
To |
|
Change Variable Type join : JoinOperatorBase<?,?,?,?> to join : InnerJoinOperatorBase<?,?,?,?> in method public testBinaryAllForwardedExceptAnnotation() : void in class org.apache.flink.api.java.functions.SemanticPropertiesTranslationTest |
From |
To |