|
Rename Method public extractWatermark(element Tuple2<String,Integer>, currentTimestamp long) : long renamed to public checkAndGetNextWatermark(element Tuple2<String,Integer>, extractedTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2TimestampExtractor |
From |
To |
|
Rename Method public extractTimestamp(value Tuple5<Integer,String,Character,Double,Boolean>, currentTimestamp long) : long renamed to public extractAscendingTimestamp(element Tuple5<Integer,String,Character,Double,Boolean>, currentTimestamp long) : long in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyTimestampExtractor |
From |
To |
|
Rename Method public extractWatermark(element Integer, currentTimestamp long) : long renamed to public checkAndGetNextWatermark(lastElement Integer, extractedTimestamp long) : long in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.LinearTimestamp |
From |
To |
|
Rename Method public extractTimestamp(element Tuple4<Integer,Integer,Double,Long>, currentTimestamp long) : long renamed to public extractAscendingTimestamp(element Tuple4<Integer,Integer,Double,Long>, previous long) : long in class org.apache.flink.streaming.examples.windowing.TopSpeedWindowing.CarTimestamp |
From |
To |
|
Rename Method public extractTimestamp(element Tuple3<Long,String,Integer>, currentTimestamp long) : long renamed to public extractAscendingTimestamp(element Tuple3<Long,String,Integer>, currentTimestamp long) : long in class org.apache.flink.streaming.examples.join.WindowJoin.MyTimestampExtractor |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2KeyExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPunctuatedWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple3TimestampExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.WindowFoldITCase.Tuple2TimestampExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPunctuatedWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple3KeyExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPunctuatedWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple3KeyExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.WindowFoldITCase.Tuple2TimestampExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple3TimestampExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPunctuatedWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2KeyExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2TimestampExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPunctuatedWatermarksOperator |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2TimestampExtractor to private serialVersionUID : long from class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator |
From |
To |
|
Rename Parameter currentTimestamp : long to extractedTimestamp : long in method public checkAndGetNextWatermark(lastElement Integer, extractedTimestamp long) : long in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.LinearTimestamp |
From |
To |
|
Rename Parameter currentTimestamp : long to extractedTimestamp : long in method public checkAndGetNextWatermark(element Tuple2<String,Integer>, extractedTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2TimestampExtractor |
From |
To |
|
Rename Parameter currentTimestamp : long to previousElementTimestamp : long in method public extractTimestamp(element Integer, previousElementTimestamp long) : long in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.LinearTimestamp |
From |
To |
|
Rename Parameter currentTimestamp : long to previous : long in method public extractAscendingTimestamp(element Tuple4<Integer,Integer,Double,Long>, previous long) : long in class org.apache.flink.streaming.examples.windowing.TopSpeedWindowing.CarTimestamp |
From |
To |
|
Rename Parameter element : Integer to lastElement : Integer in method public checkAndGetNextWatermark(lastElement Integer, extractedTimestamp long) : long in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.LinearTimestamp |
From |
To |
|
Rename Parameter currentTimestamp : long to previousTimestamp : long in method public extractTimestamp(element Tuple3<String,String,Integer>, previousTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple3TimestampExtractor |
From |
To |
|
Rename Parameter value : Tuple5<Integer,String,Character,Double,Boolean> to element : Tuple5<Integer,String,Character,Double,Boolean> in method public extractAscendingTimestamp(element Tuple5<Integer,String,Character,Double,Boolean>, currentTimestamp long) : long in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyTimestampExtractor |
From |
To |
|
Rename Parameter currentTimestamp : long to previousTimestamp : long in method public extractTimestamp(element Tuple2<String,Integer>, previousTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.WindowFoldITCase.Tuple2TimestampExtractor |
From |
To |
|
Rename Parameter currentTimestamp : long to previousTimestamp : long in method public extractTimestamp(value Tuple2<Date,HashMap<Character,Integer>>, previousTimestamp long) : long in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.Timestamp6 |
From |
To |
|
Rename Parameter currentTimestamp : long to previousTimestamp : long in method public extractTimestamp(element Tuple2<String,Integer>, previousTimestamp long) : long in class org.apache.flink.streaming.runtime.operators.windowing.CoGroupJoinITCase.Tuple2TimestampExtractor |
From |
To |