|
Pull Up Attribute private combinedWatermark : long from class org.apache.flink.streaming.api.operators.co.CoStreamMap to private combinedWatermark : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private input2Watermark : long from class org.apache.flink.streaming.api.operators.co.CoStreamMap to private input2Watermark : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private input1Watermark : long from class org.apache.flink.streaming.api.operators.co.CoStreamMap to private input1Watermark : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private input2Watermark : long from class org.apache.flink.streaming.api.operators.co.CoStreamFlatMap to private input2Watermark : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private combinedWatermark : long from class org.apache.flink.streaming.api.operators.co.CoStreamFlatMap to private combinedWatermark : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private input1Watermark : long from class org.apache.flink.streaming.api.operators.co.CoStreamFlatMap to private input1Watermark : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Variable Type toRun : List<Map.Entry<Long,List<Triggerable>>> to toRun : List<Map.Entry<Long,List<ScheduledTimerFuture>>> in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService |
From |
To |
|
Change Variable Type tasks : List<Triggerable> to tasks : List<ScheduledTimerFuture> in method public registerTimer(timestamp long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService |
From |
To |
|
Change Variable Type it : Iterator<Map.Entry<Long,List<Triggerable>>> to it : Iterator<Map.Entry<Long,List<ScheduledTimerFuture>>> in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService |
From |
To |
|
Change Variable Type tasks : Map.Entry<Long,List<Triggerable>> to tasks : Map.Entry<Long,List<ScheduledTimerFuture>> in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService |
From |
To |
|
Change Variable Type t : Map.Entry<Long,List<Triggerable>> to t : Map.Entry<Long,List<ScheduledTimerFuture>> in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService |
From |
To |
|
Change Variable Type tasks : List<Triggerable> to tasks : List<ScheduledTimerFuture> in method public getNumRegisteredTimers() : int in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService |
From |
To |
|
Change Variable Type task : Triggerable to task : ScheduledTimerFuture in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService |
From |
To |