|
Change Return Type boolean to void in method public emitWindow(collector Collector<StreamWindow<T>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingPreReducer |
From |
To |
|
Change Return Type boolean to void in method public emitWindow(collector Collector<StreamWindow<T>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.BasicWindowBuffer |
From |
To |
|
Change Return Type List<StreamWindow<T>> to List<StreamWindow<X>> in method public split(window StreamWindow<X>, n int) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Return Type List<StreamWindow<T>> to List<StreamWindow<X>> in method public partitionBy(streamWindow StreamWindow<X>, keySelector KeySelector<X,?>, withKey boolean) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Return Type boolean to void in method public emitWindow(collector Collector<StreamWindow<T>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.TumblingGroupedPreReducer |
From |
To |
|
Change Return Type boolean to void in method public emitWindow(collector Collector<StreamWindow<T>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.TumblingPreReducer |
From |
To |
|
Change Variable Type value : T to value : X in method public partitionBy(streamWindow StreamWindow<X>, keySelector KeySelector<X,?>, withKey boolean) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Variable Type currentSubWindow : StreamWindow<T> to currentSubWindow : StreamWindow<X> in method public split(window StreamWindow<X>, n int) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Variable Type element : T to element : X in method public split(window StreamWindow<X>, n int) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Variable Type split : List<StreamWindow<T>> to split : List<StreamWindow<X>> in method public split(window StreamWindow<X>, n int) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Variable Type output : List<StreamWindow<T>> to output : List<StreamWindow<X>> in method public partitionBy(streamWindow StreamWindow<X>, keySelector KeySelector<X,?>, withKey boolean) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Variable Type window : StreamWindow<T> to window : StreamWindow<X> in method public partitionBy(streamWindow StreamWindow<X>, keySelector KeySelector<X,?>, withKey boolean) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |
|
Change Variable Type partitions : Map<Object,StreamWindow<T>> to partitions : Map<Object,StreamWindow<X>> in method public partitionBy(streamWindow StreamWindow<X>, keySelector KeySelector<X,?>, withKey boolean) : List<StreamWindow<X>> in class org.apache.flink.streaming.api.windowing.StreamWindow |
From |
To |