|
Change Parameter Type folder : FoldFunction<OUT,IN> to folder : FoldFunction<IN,OUT> in method public StreamFoldInvokable(folder FoldFunction<IN,OUT>, initialValue OUT, outTypeInformation TypeInformation<OUT>) in class org.apache.flink.streaming.api.invokable.operator.StreamFoldInvokable |
From |
To |
|
Change Parameter Type foldFunction : FoldFunction<R,OUT> to foldFunction : FoldFunction<OUT,R> in method public foldWindow(initialValue R, foldFunction FoldFunction<OUT,R>, outType TypeInformation<R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Parameter Type folder : FoldFunction<OUT,IN> to folder : FoldFunction<IN,OUT> in method public GroupedFoldInvokable(folder FoldFunction<IN,OUT>, keySelector KeySelector<IN,?>, initialValue OUT, outTypeInformation TypeInformation<OUT>) in class org.apache.flink.streaming.api.invokable.operator.GroupedFoldInvokable |
From |
To |
|
Change Parameter Type folder : FoldFunction<R,OUT> to folder : FoldFunction<OUT,R> in method public fold(initialValue R, folder FoldFunction<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type folder : FoldFunction<OUT,IN> to folder : FoldFunction<IN,OUT> in method public WindowFoldFunction(folder FoldFunction<IN,OUT>, initialValue OUT) in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowFolder.WindowFoldFunction |
From |
To |
|
Change Parameter Type folder : FoldFunction<R,OUT> to folder : FoldFunction<OUT,R> in method public fold(initialValue R, folder FoldFunction<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Parameter Type foldFunction : FoldFunction<R,OUT> to foldFunction : FoldFunction<OUT,R> in method public foldWindow(initialValue R, foldFunction FoldFunction<OUT,R>, outType TypeInformation<R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.DiscretizedStream |
From |
To |
|
Change Parameter Type foldInterface : FoldFunction<OUT,IN> to foldInterface : FoldFunction<IN,OUT> in method public getFoldReturnTypes(foldInterface FoldFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor |
From |
To |
|
Change Parameter Type folder : FoldFunction<OUT,IN> to folder : FoldFunction<IN,OUT> in method public WindowFolder(folder FoldFunction<IN,OUT>, initialValue OUT) in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowFolder |
From |
To |
|
Change Parameter Type foldInterface : FoldFunction<OUT,IN> to foldInterface : FoldFunction<IN,OUT> in method public getFoldReturnTypes(foldInterface FoldFunction<IN,OUT>, inType TypeInformation<IN>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor |
From |
To |