|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.WindowedDataStream & inlined to public maxBy(field String, first boolean) : WindowedDataStream<OUT> |
From |
To |
|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.DataStream & inlined to public minBy(field String, first boolean) : SingleOutputStreamOperator<OUT,?> |
From |
To |
|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.WindowedDataStream & inlined to public min(field String) : WindowedDataStream<OUT> |
From |
To |
|
Move And Inline Method public getSumFunction(field String, typeInfo TypeInformation<T>, config ExecutionConfig) : ReduceFunction<T> moved from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator to class org.apache.flink.streaming.api.datastream.WindowedDataStream & inlined to public sum(field String) : WindowedDataStream<OUT> |
From |
To |
|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.WindowedDataStream & inlined to public max(field String) : WindowedDataStream<OUT> |
From |
To |
|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.WindowedDataStream & inlined to public minBy(field String, first boolean) : WindowedDataStream<OUT> |
From |
To |
|
Move And Inline Method public getSumFunction(field String, typeInfo TypeInformation<T>, config ExecutionConfig) : ReduceFunction<T> moved from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator to class org.apache.flink.streaming.api.datastream.DataStream & inlined to public sum(field String) : SingleOutputStreamOperator<OUT,?> |
From |
To |
|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.DataStream & inlined to public min(field String) : SingleOutputStreamOperator<OUT,?> |
From |
To |
|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.DataStream & inlined to public maxBy(field String, first boolean) : SingleOutputStreamOperator<OUT,?> |
From |
To |
|
Move And Inline Method public getAggregator(field String, typeInfo TypeInformation<R>, aggregationType AggregationType, first boolean, config ExecutionConfig) : AggregationFunction<R> moved from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator to class org.apache.flink.streaming.api.datastream.DataStream & inlined to public max(field String) : SingleOutputStreamOperator<OUT,?> |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.SimpleSumAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.TupleSumAggregator to package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator.SimpleComparableAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.PojoSumAggregator to package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator.ArrayComparableAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.ArraySumAggregator to package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator.PojoComparableAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.PojoSumAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator.TupleComparableAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.SimpleSumAggregator to package adder : SumFunction from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.ArraySumAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator.TupleSumAggregator to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |