|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<OUT> in method public projectTupleX() : SingleOutputStreamOperator<OUT> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public reduce(reducer ReduceFunction<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(preAggregator ReduceFunction<T>, function AllWindowFunction<T,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method public setBufferTimeout(timeoutMillis long) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple3<T0,T1,T2>,?> to SingleOutputStreamOperator<Tuple3<T0,T1,T2>> in method public projectTuple3() : SingleOutputStreamOperator<Tuple3<T0,T1,T2>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>,?> to SingleOutputStreamOperator<Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> in method public projectTuple14() : SingleOutputStreamOperator<Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(reduceFunction ReduceFunction<T>, 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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public minBy(positionToMinBy int) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>,?> to SingleOutputStreamOperator<Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>> in method public projectTuple25() : SingleOutputStreamOperator<Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator OneInputStreamOperator<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple7<T0,T1,T2,T3,T4,T5,T6>,?> to SingleOutputStreamOperator<Tuple7<T0,T1,T2,T3,T4,T5,T6>> in method public projectTuple7() : SingleOutputStreamOperator<Tuple7<T0,T1,T2,T3,T4,T5,T6>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public min(positionToMin int) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public min(field String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>,?> to SingleOutputStreamOperator<Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>> in method public projectTuple9() : SingleOutputStreamOperator<Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public assignTimestampsAndWatermarks(timestampAndWatermarkAssigner AssignerWithPunctuatedWatermarks<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>,?> to SingleOutputStreamOperator<Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> in method public projectTuple13() : SingleOutputStreamOperator<Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public project(fieldIndexes int...) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public fold(initialValue R, folder FoldFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public assignTimestampsAndWatermarks(timestampAndWatermarkAssigner AssignerWithPeriodicWatermarks<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method protected aggregate(aggregate AggregationFunction<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>,?> to SingleOutputStreamOperator<Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> in method public projectTuple19() : SingleOutputStreamOperator<Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 O to SingleOutputStreamOperator<T> in method public returns(typeClass Class<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<R> in method public flatMap(coFlatMapper CoFlatMapFunction<IN1,IN2,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type O to SingleOutputStreamOperator<T> in method public returns(typeInfoString String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method public startNewChain() : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public sum(field String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 O to SingleOutputStreamOperator<T> in method public returns(typeInfo TypeInformation<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method public slotSharingGroup(slotSharingGroup String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public filter(filter FilterFunction<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>,?> to SingleOutputStreamOperator<Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> in method public projectTuple18() : SingleOutputStreamOperator<Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(preAggregator ReduceFunction<T>, function AllWindowFunction<T,R,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public minBy(field String, first boolean) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(initialValue R, foldFunction FoldFunction<T,R>, function AllWindowFunction<R,R,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>,?> to SingleOutputStreamOperator<Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> in method public projectTuple12() : SingleOutputStreamOperator<Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method private setChainingStrategy(strategy ChainingStrategy) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(initialValue R, foldFunction FoldFunction<T,R>, function WindowFunction<R,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple1<T0>,?> to SingleOutputStreamOperator<Tuple1<T0>> in method public projectTuple1() : SingleOutputStreamOperator<Tuple1<T0>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public maxBy(positionToMaxBy int) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple5<T0,T1,T2,T3,T4>,?> to SingleOutputStreamOperator<Tuple5<T0,T1,T2,T3,T4>> in method public projectTuple5() : SingleOutputStreamOperator<Tuple5<T0,T1,T2,T3,T4>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method public setParallelism(parallelism int) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>,?> to SingleOutputStreamOperator<Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> in method public projectTuple20() : SingleOutputStreamOperator<Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(initialValue R, foldFunction FoldFunction<T,R>, function AllWindowFunction<R,R,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public max(positionToMax int) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public flatMap(flatMapper FlatMapFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>,?> to SingleOutputStreamOperator<Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>> in method public projectTuple24() : SingleOutputStreamOperator<Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>,?> to SingleOutputStreamOperator<Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> in method public projectTuple17() : SingleOutputStreamOperator<Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public maxBy(positionToMaxBy String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public sum(positionToSum int) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public maxBy(field String, first boolean) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>,?> to SingleOutputStreamOperator<Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> in method public projectTuple11() : SingleOutputStreamOperator<Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<R> in method public map(coMapper CoMapFunction<IN1,IN2,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public max(field String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.AllWindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public minBy(positionToMinBy int, first boolean) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method public disableChaining() : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple2<T0,T1>,?> to SingleOutputStreamOperator<Tuple2<T0,T1>> in method public projectTuple2() : SingleOutputStreamOperator<Tuple2<T0,T1>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>,?> to SingleOutputStreamOperator<Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>> in method public projectTuple8() : SingleOutputStreamOperator<Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<?,?> to SingleOutputStreamOperator<?> in method private createOutput(boltId String, bolt IRichBolt, inputStreams Map<GlobalStreamId,DataStream<Tuple>>) : SingleOutputStreamOperator<?> in class org.apache.flink.storm.api.FlinkTopology |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>,?> to SingleOutputStreamOperator<Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> in method public projectTuple16() : SingleOutputStreamOperator<Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public max(field String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public maxBy(positionToMaxBy int, first boolean) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public minBy(positionToMinBy String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>,?> to SingleOutputStreamOperator<Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> in method public projectTuple21() : SingleOutputStreamOperator<Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public map(mapper MapFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator OneInputStreamOperator<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>,?> to SingleOutputStreamOperator<Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> in method public projectTuple23() : SingleOutputStreamOperator<Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method public uid(uid String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<T,O> to SingleOutputStreamOperator<T> in method public name(name String) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple4<T0,T1,T2,T3>,?> to SingleOutputStreamOperator<Tuple4<T0,T1,T2,T3>> in method public projectTuple4() : SingleOutputStreamOperator<Tuple4<T0,T1,T2,T3>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<T,?> to SingleOutputStreamOperator<T> in method public assignTimestamps(extractor TimestampExtractor<T>) : SingleOutputStreamOperator<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>,?> to SingleOutputStreamOperator<Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>> in method public projectTuple10() : SingleOutputStreamOperator<Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>,?> to SingleOutputStreamOperator<Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> in method public projectTuple15() : SingleOutputStreamOperator<Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>,?> to SingleOutputStreamOperator<Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> in method public projectTuple22() : SingleOutputStreamOperator<Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<R> in method public transform(functionName String, outTypeInfo TypeInformation<R>, operator TwoInputStreamOperator<IN1,IN2,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type SingleOutputStreamOperator<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 SingleOutputStreamOperator<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 SingleOutputStreamOperator<R,?> to SingleOutputStreamOperator<R> in method public apply(initialValue R, foldFunction FoldFunction<T,R>, function WindowFunction<R,R,K,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<Tuple6<T0,T1,T2,T3,T4,T5>,?> to SingleOutputStreamOperator<Tuple6<T0,T1,T2,T3,T4,T5>> in method public projectTuple6() : SingleOutputStreamOperator<Tuple6<T0,T1,T2,T3,T4,T5>> in class org.apache.flink.streaming.api.datastream.StreamProjection |
From |
To |