0a501e9f7f56baba2905002b74746998458db007
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable fireTimestamp : ReducingState<Long> to fireTimestampState : ReducingState<Long> in method public onEventTime(time long, window W, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger | From | To | |
| Extract Method | 1 | ||
| Extract Method private invokeOnEventTime(timer TestInternalTimerService.Timer<Integer,W>) : TriggerResult extracted from public advanceWatermark(time long) : Collection<Tuple2<W,TriggerResult>> in class org.apache.flink.streaming.runtime.operators.windowing.TriggerTestHarness | From | To |