|
Change Variable Type type1 : TypeInformation<Tuple2<Integer,Integer>> to typeInfo : TypeInformation<Tuple3<Integer,Integer,Integer>> in method public minMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type maxByFunctionLast : ReduceFunction<Tuple2<Integer,Integer>> to maxByFunctionLast : ReduceFunction<Tuple3<Integer,Integer,Integer>> in method public minMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type type1 : TypeInformation<MyPojo> to typeInfo : TypeInformation<MyPojo3> in method public pojoMinMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type maxByFunctionFirst : ReduceFunction<MyPojo> to maxByFunctionFirst : ReduceFunction<MyPojo3> in method public pojoMinMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type minByFunctionLast : ReduceFunction<Tuple2<Integer,Integer>> to minByFunctionLast : ReduceFunction<Tuple3<Integer,Integer,Integer>> in method public minMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type minByFunctionFirst : ReduceFunction<Tuple2<Integer,Integer>> to minByFunctionFirst : ReduceFunction<Tuple3<Integer,Integer,Integer>> in method public minMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type minByFunctionFirst : ReduceFunction<MyPojo> to minByFunctionFirst : ReduceFunction<MyPojo3> in method public pojoMinMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type minByFunctionLast : ReduceFunction<MyPojo> to minByFunctionLast : ReduceFunction<MyPojo3> in method public pojoMinMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type maxByFunctionFirst : ReduceFunction<Tuple2<Integer,Integer>> to maxByFunctionFirst : ReduceFunction<Tuple3<Integer,Integer,Integer>> in method public minMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |
|
Change Variable Type maxByFunctionLast : ReduceFunction<MyPojo> to maxByFunctionLast : ReduceFunction<MyPojo3> in method public pojoMinMaxByTest() : void in class org.apache.flink.streaming.api.AggregationFunctionTest |
From |
To |