a0f4239faee533545c6d923a944f242b519759d1
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Variable | 2 | ||
| Extract Variable timerService : TimerService in method public processElement(value Integer, ctx Context, out Collector<String>) : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.BothTriggeringFlatMapFunction | From | To | |
| Extract Variable timerService : TimerService in method public processElement(value Integer, ctx Context, out Collector<String>) : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.TriggeringStatefulFlatMapFunction | From | To | |
| Extract Method | 4 | ||
| Extract Method private handleValue(value Object, out Collector<String>, timerService TimerService, channel int) : void extracted from public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.EventTimeTriggeringStatefulProcessFunction | From | To | |
| Extract Method private handleValue(value Object, out Collector<String>, timerService TimerService, channel int) : void extracted from public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.ProcessingTimeTriggeringStatefulProcessFunction | From | To | |
| Extract Method private handleValue(value Object, out Collector<String>, timerService TimerService, channel int) : void extracted from public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.ProcessingTimeTriggeringStatefulProcessFunction | From | To | |
| Extract Method private handleValue(value Object, out Collector<String>, timerService TimerService, channel int) : void extracted from public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest.EventTimeTriggeringStatefulProcessFunction | From | To |