|
Rename Method public extractTimestamp(extractor TimestampExtractor<T>) : SingleOutputStreamOperator<T,?> renamed to public assignTimestamps(extractor TimestampExtractor<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method public emitWatermark(value Tuple5<Integer,String,Character,Double,Boolean>, currentTimestamp long) : long renamed to public extractWatermark(value Tuple5<Integer,String,Character,Double,Boolean>, currentTimestamp long) : long in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyTimestampExtractor |
From |
To |
|
Rename Method public emitWatermark(element Tuple3<Long,String,Integer>, currentTimestamp long) : long renamed to public extractWatermark(element Tuple3<Long,String,Integer>, currentTimestamp long) : long in class org.apache.flink.streaming.examples.join.WindowJoin.MyTimestampExtractor |
From |
To |
|
Rename Method public emitWatermark(element Tuple3<String,String,Integer>, currentTimestamp long) : long renamed to public extractWatermark(element Tuple3<String,String,Integer>, currentTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple3TimestampExtractor |
From |
To |
|
Rename Method public emitWatermark(element Integer, currentTimestamp long) : long renamed to public extractWatermark(element Integer, currentTimestamp long) : long in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.LinearTimestamp |
From |
To |
|
Rename Method public emitWatermark(element T, currentTimestamp long) : long renamed to public extractWatermark(element T, currentTimestamp long) : long in class org.apache.flink.streaming.api.functions.TimestampExtractor |
From |
To |
|
Rename Method public emitWatermark(element T, currentTimestamp long) : long renamed to public extractWatermark(element T, currentTimestamp long) : long in class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor |
From |
To |
|
Rename Method public emitWatermark(element Tuple4<Integer,Integer,Double,Long>, currentTimestamp long) : long renamed to public extractWatermark(element Tuple4<Integer,Integer,Double,Long>, currentTimestamp long) : long in class org.apache.flink.streaming.examples.windowing.TopSpeedWindowing.CarTimestamp |
From |
To |
|
Rename Method public emitWatermark(element Tuple2<String,Integer>, currentTimestamp long) : long renamed to public extractWatermark(element Tuple2<String,Integer>, currentTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.WindowFoldITCase.Tuple2TimestampExtractor |
From |
To |
|
Rename Method public emitWatermark(value Tuple2<Date,HashMap<Character,Integer>>, currentTimestamp long) : long renamed to public extractWatermark(value Tuple2<Date,HashMap<Character,Integer>>, currentTimestamp long) : long in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.Timestamp6 |
From |
To |
|
Rename Method public emitWatermark(element Tuple2<String,Integer>, currentTimestamp long) : long renamed to public extractWatermark(element Tuple2<String,Integer>, currentTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2TimestampExtractor |
From |
To |