159986292e35a71737bcc434d5f20f385973fafa
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 11
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public testKeyedProcessTranslation() : void renamed to public testKeyedStreamProcessTranslation() : void in class org.apache.flink.streaming.api.DataStreamTest | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type function : ProcessFunction<IN,OUT> to function : KeyedProcessFunction<K,IN,OUT> in method package OnTimerContextImpl(function KeyedProcessFunction<K,IN,OUT>, timerService TimerService) in class org.apache.flink.streaming.api.operators.KeyedProcessOperator.OnTimerContextImpl | From | To | |
| Change Parameter Type function : ProcessFunction<IN,OUT> to function : KeyedProcessFunction<K,IN,OUT> in method public KeyedProcessOperator(function KeyedProcessFunction<K,IN,OUT>) in class org.apache.flink.streaming.api.operators.KeyedProcessOperator | From | To | |
| Change Parameter Type function : ProcessFunction<IN,OUT> to function : KeyedProcessFunction<K,IN,OUT> in method package ContextImpl(function KeyedProcessFunction<K,IN,OUT>, timerService TimerService) in class org.apache.flink.streaming.api.operators.KeyedProcessOperator.ContextImpl | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.api.functions.KeyedProcessFunction from classes [org.apache.flink.streaming.api.operators.KeyedProcessOperator.ContextImpl, org.apache.flink.streaming.api.operators.KeyedProcessOperator.OnTimerContextImpl, org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.NullOutputTagEmittingProcessFunction, org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.SideOutputProcessFunction, org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.QueryingFlatMapFunction, org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.TriggeringFlatMapFunction, org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.TriggeringStatefulFlatMapFunction, org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.BothTriggeringFlatMapFunction] | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute timeDomain : TimeDomain to expectedTimeDomain : TimeDomain in class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.TriggeringStatefulFlatMapFunction | From | To | |
| Rename Attribute timeDomain : TimeDomain to expectedTimeDomain : TimeDomain in class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.TriggeringFlatMapFunction | From | To | |
| Rename Attribute timeDomain : TimeDomain to expectedTimeDomain : TimeDomain in class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.QueryingFlatMapFunction | From | To | |
| Extract Variable | 3 | ||
| Extract Variable expectedKey : int in method public testSnapshotAndRestore() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest | From | To | |
| Extract Variable expectedKey : int in method public testEventTimeTimers() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest | From | To | |
| Extract Variable expectedKey : int in method public testProcessingTimeTimers() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type operator : KeyedProcessOperator<KEY,T,R> to operator : LegacyKeyedProcessOperator<KEY,T,R> in method public process(processFunction ProcessFunction<T,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.KeyedStream | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type timer : InternalTimer<?,VoidNamespace> to timer : InternalTimer<K,VoidNamespace> in class org.apache.flink.streaming.api.operators.KeyedProcessOperator.OnTimerContextImpl | From | To | |
| Extract Method | 2 | ||
| Extract Method private invokeUserFunction(timeDomain TimeDomain, timer InternalTimer<K,VoidNamespace>) : void extracted from public onProcessingTime(timer InternalTimer<K,VoidNamespace>) : void in class org.apache.flink.streaming.api.operators.KeyedProcessOperator | From | To | |
| Extract Method private invokeUserFunction(timeDomain TimeDomain, timer InternalTimer<K,VoidNamespace>) : void extracted from public onEventTime(timer InternalTimer<K,VoidNamespace>) : void in class org.apache.flink.streaming.api.operators.KeyedProcessOperator | From | To |