ce8f966c821ceab47c5041ac46f11a55ff3321f0
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 18
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Move And Rename Method | 1 | ||
Move And Rename Method public testFastTimeWindows() : void from class org.apache.flink.streaming.runtime.operators.windowing.WindowTranslationTest to public testEventTimeWindows() : void from class org.apache.flink.streaming.runtime.operators.windowing.TimeWindowTranslationTest | From | To | |
Change Variable Type | 2 | ||
Change Variable Type timeWindows : TumblingTimeWindows to timeWindows : TumblingProcessingTimeWindows in method private createFastTimeOperatorIfValid(function Function, resultType TypeInformation<R>, functionName String) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream | From | To | |
Change Variable Type timeWindows : SlidingTimeWindows to timeWindows : SlidingProcessingTimeWindows in method private createFastTimeOperatorIfValid(function Function, resultType TypeInformation<R>, functionName String) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.WindowedStream | From | To |