flink bb5dc7e3dd6825f8f78f42df6c4ca5ef00d520fe

bb5dc7e3dd6825f8f78f42df6c4ca5ef00d520fe

Files Diff

Added: 19
Removed: 17
Renamed: 0
Modified: 22

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Method	3
Rename Method public reduce(values Iterable<Integer>, out Collector<Double[]>) : void renamed to public mapWindow(values Iterable<Integer>, out Collector<Double[]>) : void in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.PartialModelBuilder	From	To
Rename Method public reduce(values Iterable<StockPrice>, out Collector<String>) : void renamed to public mapWindow(values Iterable<StockPrice>, out Collector<String>) : void in class org.apache.flink.streaming.examples.windowing.StockPrices.SendWarning	From	To
Rename Method public reduce(values Iterable<Integer>, out Collector<StreamWindow<Integer>>) : void renamed to public mapWindow(values Iterable<Integer>, out Collector<StreamWindow<Integer>>) : void in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowIntegrationTest.IdentityWindowMap	From	To
Change Parameter Type	4
Change Parameter Type reduceFunction : GroupReduceFunction<OUT,R> to windowMapFunction : WindowMapFunction<OUT,R> in method public mapWindow(windowMapFunction WindowMapFunction<OUT,R>, returnType TypeInformation<R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.DiscretizedStream	From	To
Change Parameter Type reduceFunction : GroupReduceFunction<OUT,R> to windowMapFunction : WindowMapFunction<OUT,R> in method public mapWindow(windowMapFunction WindowMapFunction<OUT,R>) : WindowedDataStream<R> in class org.apache.flink.streaming.api.datastream.WindowedDataStream	From	To
Change Parameter Type reducer : GroupReduceFunction<T,R> to mapper : WindowMapFunction<T,R> in method public WindowMap(mapper WindowMapFunction<T,R>) in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper.WindowMap	From	To
Change Parameter Type reducer : GroupReduceFunction<IN,OUT> to mapper : WindowMapFunction<IN,OUT> in method public WindowMapper(mapper WindowMapFunction<IN,OUT>) in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper	From	To
Inline Method	1
Inline Method public clean(f F) : F inlined to private groupBy(keys Keys<OUT>) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream	From	To
Rename Class	1
Rename Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper.WindowMapfunction renamed to org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper.WindowMap	From	To
Move Class	17
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowBuffer moved to org.apache.flink.streaming.api.windowing.windowbuffer.WindowBuffer	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.StreamWindowTypeInfo moved to org.apache.flink.streaming.api.windowing.StreamWindowTypeInfo	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.TumblingPreReducerTest moved to org.apache.flink.streaming.api.windowing.windowbuffer.TumblingPreReducerTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.TumblingPreReducer moved to org.apache.flink.streaming.api.windowing.windowbuffer.TumblingPreReducer	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.CoMapTest moved to org.apache.flink.streaming.api.invokable.operator.co.CoMapTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.CoStreamReduceTest moved to org.apache.flink.streaming.api.invokable.operator.co.CoStreamReduceTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.StreamWindowTest moved to org.apache.flink.streaming.api.windowing.StreamWindowTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.BasicWindowBufferTest moved to org.apache.flink.streaming.api.windowing.windowbuffer.BasicWindowBufferTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.StreamWindowSerializer moved to org.apache.flink.streaming.api.windowing.StreamWindowSerializer	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.TumblingGroupedPreReducer moved to org.apache.flink.streaming.api.windowing.windowbuffer.TumblingGroupedPreReducer	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.CoGroupedReduceTest moved to org.apache.flink.streaming.api.invokable.operator.co.CoGroupedReduceTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.CoWindowTest moved to org.apache.flink.streaming.api.invokable.operator.co.CoWindowTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.StreamWindow moved to org.apache.flink.streaming.api.windowing.StreamWindow	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.BasicWindowBuffer moved to org.apache.flink.streaming.api.windowing.windowbuffer.BasicWindowBuffer	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.CompletePreAggregator moved to org.apache.flink.streaming.api.windowing.windowbuffer.CompletePreAggregator	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.CoFlatMapTest moved to org.apache.flink.streaming.api.invokable.operator.co.CoFlatMapTest	From	To
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.TumblingGroupedPreReducerTest moved to org.apache.flink.streaming.api.windowing.windowbuffer.TumblingGroupedPreReducerTest	From	To
Rename Attribute	2
Rename Attribute reducer : GroupReduceFunction<IN,OUT> to mapper : WindowMapFunction<IN,OUT> in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper	From	To
Rename Attribute reducer : GroupReduceFunction<T,R> to mapper : WindowMapFunction<T,R> in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper.WindowMap	From	To
Change Attribute Type	2
Change Attribute Type reducer : GroupReduceFunction<T,R> to mapper : WindowMapFunction<T,R> in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper.WindowMap	From	To
Change Attribute Type reducer : GroupReduceFunction<IN,OUT> to mapper : WindowMapFunction<IN,OUT> in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper	From	To
Rename Parameter	4
Rename Parameter reduceFunction : GroupReduceFunction<OUT,R> to windowMapFunction : WindowMapFunction<OUT,R> in method public mapWindow(windowMapFunction WindowMapFunction<OUT,R>) : WindowedDataStream<R> in class org.apache.flink.streaming.api.datastream.WindowedDataStream	From	To
Rename Parameter reduceFunction : GroupReduceFunction<OUT,R> to windowMapFunction : WindowMapFunction<OUT,R> in method public mapWindow(windowMapFunction WindowMapFunction<OUT,R>, returnType TypeInformation<R>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.DiscretizedStream	From	To
Rename Parameter reducer : GroupReduceFunction<T,R> to mapper : WindowMapFunction<T,R> in method public WindowMap(mapper WindowMapFunction<T,R>) in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper.WindowMap	From	To
Rename Parameter reducer : GroupReduceFunction<IN,OUT> to mapper : WindowMapFunction<IN,OUT> in method public WindowMapper(mapper WindowMapFunction<IN,OUT>) in class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper	From	To

bb5dc7e3dd6825f8f78f42df6c4ca5ef00d520fe

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: