|
Rename Method protected updateIndexAtEmit() : void renamed to protected afterEmit() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducer |
From |
To |
|
Rename Method protected addCurrentToReduce(next T) : boolean renamed to protected currentEligible(next T) : boolean in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducer |
From |
To |
|
Rename Method protected addCurrentToReduce(next T) : boolean renamed to protected currentEligible(next T) : boolean in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducer |
From |
To |
|
Rename Method protected abstract addCurrentToReduce(next T) : boolean renamed to protected abstract currentEligible(next T) : boolean in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingPreReducer |
From |
To |
|
Rename Method protected updateIndexAtEmit() : void renamed to protected afterEmit() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducer |
From |
To |
|
Rename Method public getFinalAggregate() : T renamed to public addFinalAggregate(currentWindow StreamWindow<T>) : boolean in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingPreReducer |
From |
To |
|
Change Parameter Type windowSize : int to windowSize : long in method public SlidingTimePreReducer(reducer ReduceFunction<T>, serializer TypeSerializer<T>, windowSize long, slideSize long, timestampWrapper TimestampWrapper<T>) in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducer |
From |
To |
|
Change Parameter Type windowSize : int to windowSize : long in method public SlidingCountPreReducer(reducer ReduceFunction<T>, serializer TypeSerializer<T>, windowSize long, slideSize long, start int) in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducer |
From |
To |
|
Change Parameter Type slideSize : int to slideSize : long in method public SlidingTimePreReducer(reducer ReduceFunction<T>, serializer TypeSerializer<T>, windowSize long, slideSize long, timestampWrapper TimestampWrapper<T>) in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducer |
From |
To |
|
Change Parameter Type slideSize : int to slideSize : long in method public SlidingCountPreReducer(reducer ReduceFunction<T>, serializer TypeSerializer<T>, windowSize long, slideSize long, start int) in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducer |
From |
To |