|
Rename Method public getTimestamp(value Tuple4<Integer,Integer,Double,Long>) : long renamed to public extractTimestamp(element Tuple4<Integer,Integer,Double,Long>, currentTimestamp long) : long in class org.apache.flink.streaming.examples.windowing.TopSpeedWindowing.CarTimestamp |
From |
To |
|
Rename Method public mapWindow(values Iterable<Integer>, out Collector<Double[]>) : void renamed to public apply(window TimeWindow, values Iterable<Integer>, out Collector<Double[]>) : void in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.PartialModelBuilder |
From |
To |
|
Rename Method public mapWindow(values Iterable<Tuple2<Rectangle,Integer>>, out Collector<Tuple2<Rectangle,Integer>>) : void renamed to public apply(window GlobalWindow, values Iterable<Tuple2<Rectangle,Integer>>, out Collector<Tuple2<Rectangle,Integer>>) : void in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.MyWindowMapFunction |
From |
To |
|
Rename Method public getTimestamp(value Tuple2<Date,HashMap<Character,Integer>>) : long renamed to public extractTimestamp(value Tuple2<Date,HashMap<Character,Integer>>, currentTimestamp long) : long in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest.Timestamp6 |
From |
To |
|
Rename Method public getTimestamp(value Integer) : long renamed to public extractTimestamp(element Integer, currentTimestamp long) : long in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.LinearTimestamp |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldsFromTupleTest moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromTupleTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.ArrayFromTupleTest moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTupleTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldFromTuple moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromTuple |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.ArrayFromTuple moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTuple |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldsFromArrayTest moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromArrayTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.Extractor moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.Extractor |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldFromTupleTest moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromTupleTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldsFromArray moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromArray |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldFromArrayTest moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromArrayTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.ConcatenatedExtractTest moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.ConcatenatedExtractTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldsFromTuple moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromTuple |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.FieldFromArray moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromArray |
From |
To |
|
Move Class org.apache.flink.streaming.api.windowing.extractor.ConcatenatedExtract moved to org.apache.flink.streaming.api.functions.windowing.delta.extractor.ConcatenatedExtract |
From |
To |
|
Change Variable Type connectedGroup3 : ConnectedStreams to connectedGroup3 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedPartition3 : ConnectedStreams to connectedPartition3 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type coMap : SingleOutputStreamOperator to coMap : SingleOutputStreamOperator<?,?> in method private createDownStreamId(dataStream ConnectedStreams) : Integer in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type partition1 : DataStream to partition1 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedGroup2 : ConnectedStreams to connectedGroup2 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedGroup1 : ConnectedStreams to connectedGroup1 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type partition4 : DataStream to partition4 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type customPartition1 : DataStream to customPartition1 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type customPartition4 : DataStream to customPartition4 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedPartition5 : ConnectedStreams to connectedPartition5 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedPartition2 : ConnectedStreams to connectedPartition2 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type group4 : DataStream to group4 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type group3 : DataStream to group3 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type group2 : DataStream to group2 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connected : ConnectedStreams to connected : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type group1 : DataStream to group1 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type partition3 : DataStream to partition3 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type src1 : DataStream to src1 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedPartition4 : ConnectedStreams to connectedPartition4 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedPartition1 : ConnectedStreams to connectedPartition1 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type src2 : DataStream to src2 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type partition2 : DataStream to partition2 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedGroup5 : ConnectedStreams to connectedGroup5 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedGroup4 : ConnectedStreams to connectedGroup4 : ConnectedStreams<Tuple2<Long,Long>,Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type customPartition3 : DataStream to customPartition3 : DataStream<Tuple2<Long,Long>> in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |