5623c15b0933487aea11fa8962feef29433133b7
Files Diff
- Added: 7
- Removed: 11
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 1 | ||
| Move And Rename Method public KeyedTriggerWindowDataStream(input KeyedDataStream<T,K>, windowAssigner WindowAssigner<? super T,W>) from class org.apache.flink.streaming.api.datastream.KeyedTriggerWindowDataStream to public KeyedWindowDataStream(input KeyedDataStream<T,K>, windowAssigner WindowAssigner<? super T,W>) from class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream | From | To | |
| Move Method | 1 | ||
| Move Method public mapWindow(function KeyedWindowFunction<T,R,K,W>) : DataStream<R> from class org.apache.flink.streaming.api.datastream.KeyedTriggerWindowDataStream to public mapWindow(function KeyedWindowFunction<T,R,K,W>) : DataStream<R> from class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream | From | To | |
| Change Return Type | 2 | ||
| Change Return Type KeyedTriggerWindowDataStream<T,KEY,W> to KeyedWindowDataStream<T,KEY,W> in method public window(assigner WindowAssigner<? super T,W>) : KeyedWindowDataStream<T,KEY,W> in class org.apache.flink.streaming.api.datastream.KeyedDataStream | From | To | |
| Change Return Type AbstractTimePolicy to AbstractTime in method public makeSpecificBasedOnTimeCharacteristic(timeCharacteristic TimeCharacteristic) : AbstractTime in class org.apache.flink.streaming.api.windowing.time.Time | From | To | |
| Move Attribute | 3 | ||
| Move Attribute private evictor : Evictor<? super T,? super W> from class org.apache.flink.streaming.api.datastream.KeyedTriggerWindowDataStream to private evictor : Evictor<? super T,? super W> from class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream | From | To | |
| Move Attribute private trigger : Trigger<? super T,? super W> from class org.apache.flink.streaming.api.datastream.KeyedTriggerWindowDataStream to private trigger : Trigger<? super T,? super W> from class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream | From | To | |
| Move Attribute private windowAssigner : WindowAssigner<? super T,W> from class org.apache.flink.streaming.api.datastream.KeyedTriggerWindowDataStream to private windowAssigner : WindowAssigner<? super T,W> from class org.apache.flink.streaming.api.datastream.KeyedWindowDataStream | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.runtime.operators.windowing.PolicyWindowTranslationTest renamed to org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest | From | To | |
| Move Class | 5 | ||
| Move Class org.apache.flink.streaming.api.windowing.windowpolicy.EventTime moved to org.apache.flink.streaming.api.windowing.time.EventTime | From | To | |
| Move Class org.apache.flink.streaming.runtime.operators.windowing.PolicyWindowTranslationTest.DummyReducer moved to org.apache.flink.streaming.runtime.operators.windowing.TimeWindowTranslationTest.DummyReducer | From | To | |
| Move Class org.apache.flink.streaming.runtime.operators.windowing.TriggerWindowTranslationTest.DummyReducer moved to org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest.DummyReducer | From | To | |
| Move Class org.apache.flink.streaming.api.windowing.windowpolicy.Time moved to org.apache.flink.streaming.api.windowing.time.Time | From | To | |
| Move Class org.apache.flink.streaming.api.windowing.windowpolicy.ProcessingTime moved to org.apache.flink.streaming.api.windowing.time.ProcessingTime | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.api.windowing.time.AbstractTime from classes [org.apache.flink.streaming.api.windowing.time.EventTime, org.apache.flink.streaming.api.windowing.time.ProcessingTime, org.apache.flink.streaming.api.windowing.time.Time] | From | To | |
| Change Package | 1 | ||
| Change Package org.apache.flink.streaming.api.windowing.windowpolicy to org.apache.flink.streaming.api.windowing.time | From | To |