|
Rename Method public groupBy(field1 String, field2 String) : ConnectedStreams<IN1,IN2> renamed to public keyBy(field1 String, field2 String) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Rename Method public groupBy(field1 String, field2 String) : ConnectedStreams<I,F> renamed to public keyBy(fields1 String[], fields2 String[]) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Rename Method public groupBy(fields1 String[], fields2 String[]) : ConnectedStreams<I,F> renamed to public keyBy(keySelector1 KeySelector<I,?>, keySelector2 KeySelector<F,?>) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Rename Method public groupBy(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<I,F> renamed to public keyBy(field1 String, field2 String) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Rename Method public groupBy(keyPosition1 int, keyPosition2 int) : ConnectedStreams<IN1,IN2> renamed to public keyBy(keyPosition1 int, keyPosition2 int) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Rename Method public groupBy(keySelector KeySelector<T,?>) : WindowedDataStream<T> renamed to public keyBy(keySelector KeySelector<T,?>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Rename Method public groupBy(keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>) : ConnectedStreams<IN1,IN2> renamed to public keyBy(keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Rename Method private isGrouped(dataStream DataStream) : boolean renamed to private isKeyed(dataStream DataStream) : boolean in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Rename Method public groupBy(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<IN1,IN2> renamed to public keyBy(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Rename Method private isGrouped(dataStream ConnectedStreams) : boolean renamed to private isKeyed(dataStream ConnectedStreams) : boolean in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Rename Method public groupBy(fields1 String[], fields2 String[]) : ConnectedStreams<IN1,IN2> renamed to public keyBy(fields1 String[], fields2 String[]) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Rename Method public groupBy(keyPosition1 int, keyPosition2 int) : ConnectedStreams<I,F> renamed to public keyBy(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Rename Method public groupBy(fields int...) : WindowedDataStream<T> renamed to public keyBy(fields int...) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Pull Up Method public minBy(positionToMinBy String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public minBy(positionToMinBy String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public fold(initialValue R, folder FoldFunction<T,R>) : SingleOutputStreamOperator<R,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public fold(initialValue R, folder FoldFunction<T,R>) : SingleOutputStreamOperator<R,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public maxBy(positionToMaxBy int, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public maxBy(positionToMaxBy int, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method protected aggregate(aggregate AggregationFunction<T>) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to protected aggregate(aggregate AggregationFunction<T>) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public max(field String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public max(field String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public minBy(positionToMinBy int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public minBy(positionToMinBy int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public min(positionToMin int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public min(positionToMin int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public min(field String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public min(field String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public reduce(reducer ReduceFunction<T>) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public reduce(reducer ReduceFunction<T>) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public maxBy(field String, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public maxBy(field String, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public minBy(positionToMinBy int, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public minBy(positionToMinBy int, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public sum(positionToSum int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public sum(positionToSum int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public maxBy(positionToMaxBy int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public maxBy(positionToMaxBy int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public max(positionToMax int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public max(positionToMax int) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public maxBy(positionToMaxBy String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public maxBy(positionToMaxBy String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public minBy(field String, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public minBy(field String, first boolean) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Pull Up Method public sum(field String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.GroupedDataStream to public sum(field String) : SingleOutputStreamOperator<T,?> from class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |