|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator |
From |
To |
|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink |
From |
To |
|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.runtime.operators.StreamTaskTimerTest.ValidatingProcessingTimeCallback |
From |
To |
|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.runtime.operators.ExtractTimestampsOperator |
From |
To |
|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext.WatermarkEmittingTask |
From |
To |
|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator |
From |
To |
|
Rename Method public trigger(time long) : void renamed to public onProcessingTime(time long) : void in class org.apache.flink.test.streaming.runtime.StreamTaskTimerITCase.TimerOperator |
From |
To |
|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback |
From |
To |
|
Rename Method public trigger(timestamp long) : void renamed to public onProcessingTime(timestamp long) : void in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.PeriodicWatermarkEmitter |
From |
To |
|
Rename Method public trigger(time long) : void renamed to public onProcessingTime(time long) : void in class org.apache.flink.streaming.api.operators.HeapInternalTimerService |
From |
To |
|
Rename Method public trigger(time long) : void renamed to public onProcessingTime(time long) : void in class org.apache.flink.test.streaming.runtime.StreamTaskTimerITCase.TwoInputTimerOperator |
From |
To |