34a8b03d2ad40db7dc00fa47923b96374c289838
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 18
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Inline Method | 2 | ||
| Inline Method protected processTriggerResult(triggerResult TriggerResult, window W) : void inlined to public trigger(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator | From | To | |
| Inline Method private processTriggersFor(mark Watermark) : void inlined to public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator | From | To | |
| Extract Method | 2 | ||
| Extract Method private cleanup(window W, windowState ListState<StreamRecord<IN>>, mergingWindows MergingWindowSet<W>) : void extracted from public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator | From | To | |
| Extract Method private cleanup(window W, windowState AppendingState<IN,ACC>, mergingWindows MergingWindowSet<W>) : void extracted from public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator | From | To |