|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public sum(positionToSum int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public fold(initialValue R, function FoldFunction<T,R>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public min(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy int, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(field String, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method private createFastTimeOperatorIfValid(function Function, resultType TypeInformation<R>, functionName String) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public min(positionToMin int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public min(positionToMin int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(field String, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy int, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public max(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method private aggregate(aggregator AggregationFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public apply(function WindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public fold(initialValue R, function FoldFunction<T,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public reduce(function ReduceFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public apply(function AllWindowFunction<T,R,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(field String, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public apply(function WindowFunction<T,R,K,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy int, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public apply(function AllWindowFunction<T,R,W>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public max(positionToMax int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method private createFastTimeOperatorIfValid(function Function, resultType TypeInformation<R>, functionName String) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public sum(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public reduce(function ReduceFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public fold(initialValue R, function FoldFunction<T,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public max(positionToMax int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public min(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy int, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(field String, first boolean) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R,?> in method public fold(initialValue R, function FoldFunction<T,R>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public sum(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public sum(positionToSum int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method private aggregate(aggregator AggregationFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public minBy(positionToMinBy int) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public maxBy(positionToMaxBy String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type DataStream<T> to SingleOutputStreamOperator<T,?> in method public max(field String) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |