|
Move Method public testSnapshotAndRestore() : void from class org.apache.flink.streaming.api.operators.ProcessOperatorTest to public testSnapshotAndRestore() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest |
From |
To |
|
Move Method public onProcessingTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.ProcessOperator to public onProcessingTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperator |
From |
To |
|
Move Method public testEventTimeTimers() : void from class org.apache.flink.streaming.api.operators.ProcessOperatorTest to public testEventTimeTimers() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest |
From |
To |
|
Move Method public onEventTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.ProcessOperator to public onEventTime(timer InternalTimer<K,VoidNamespace>) : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperator |
From |
To |
|
Move Method public testProcessingTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.ProcessOperatorTest to public testProcessingTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest |
From |
To |
|
Move Method public testEventTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.ProcessOperatorTest to public testEventTimeTimerWithState() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest |
From |
To |
|
Move Method public testProcessingTimeTimers() : void from class org.apache.flink.streaming.api.operators.ProcessOperatorTest to public testProcessingTimeTimers() : void from class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.operators.ProcessOperatorTest.BothTriggeringFlatMapFunction moved to org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.BothTriggeringFlatMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.operators.ProcessOperatorTest.IdentityKeySelector moved to org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.IdentityKeySelector |
From |
To |
|
Move Class org.apache.flink.streaming.api.operators.ProcessOperatorTest.QueryingFlatMapFunction moved to org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.QueryingFlatMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.operators.ProcessOperatorTest.TriggeringFlatMapFunction moved to org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.TriggeringFlatMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.operators.ProcessOperatorTest.TriggeringStatefulFlatMapFunction moved to org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest.TriggeringStatefulFlatMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.operators.ProcessOperator.OnTimerContextImpl moved to org.apache.flink.streaming.api.operators.KeyedProcessOperator.OnTimerContextImpl |
From |
To |
|
Change Variable Type operator : ProcessOperator<KEY,T,R> to operator : KeyedProcessOperator<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 Variable Type operator : ProcessOperator<Integer,Integer,String> to operator : ProcessOperator<Integer,String> in method public testTimestampAndProcessingTimeQuerying() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |
|
Change Variable Type operator : ProcessOperator<Integer,Integer,String> to operator : ProcessOperator<Integer,String> in method public testTimestampAndWatermarkQuerying() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |