|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public groupBy(field1 String, field2 String) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedIterativeDataStream<T,F> to ConnectedIterativeDataStreams<T,F> in method public withFeedbackType(feedbackType TypeInformation<F>) : ConnectedIterativeDataStreams<T,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Return Type ConnectedDataStream<T,R> to ConnectedStreams<T,R> in method public connect(dataStream DataStream<R>) : ConnectedStreams<T,R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public groupBy(fields1 String[], fields2 String[]) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public partitionByHash(keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public groupBy(keyPosition1 int, keyPosition2 int) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public partitionByHash(keySelector1 KeySelector<I,?>, keySelector2 KeySelector<F,?>) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public groupBy(keyPosition1 int, keyPosition2 int) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public groupBy(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public partitionByHash(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public partitionByHash(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public groupBy(keySelector1 KeySelector<I,?>, keySelector2 KeySelector<F,?>) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public partitionByHash(fields1 String[], fields2 String[]) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public groupBy(field1 String, field2 String) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedIterativeDataStream<T,F> to ConnectedIterativeDataStreams<T,F> in method public withFeedbackType(feedbackTypeClass Class<F>) : ConnectedIterativeDataStreams<T,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public groupBy(keyPositions1 int[], keyPositions2 int[]) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public partitionByHash(fields1 String[], fields2 String[]) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public partitionByHash(keyPosition1 int, keyPosition2 int) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public partitionByHash(field1 String, field2 String) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public partitionByHash(keyPosition1 int, keyPosition2 int) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedIterativeDataStream<T,F> to ConnectedIterativeDataStreams<T,F> in method public withFeedbackType(feedbackTypeString String) : ConnectedIterativeDataStreams<T,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public groupBy(keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Return Type ConnectedDataStream<I,F> to ConnectedStreams<I,F> in method public groupBy(fields1 String[], fields2 String[]) : ConnectedStreams<I,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream.ConnectedIterativeDataStreams |
From |
To |
|
Change Return Type ConnectedDataStream<IN1,IN2> to ConnectedStreams<IN1,IN2> in method public partitionByHash(field1 String, field2 String) : ConnectedStreams<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Variable Type connectedPartition2 : ConnectedDataStream to connectedPartition2 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type coIter : ConnectedIterativeDataStream<Integer,Integer> to coIter : ConnectedIterativeDataStreams<Integer,Integer> in method public testCoDifferingParallelism() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type connectedGroup5 : ConnectedDataStream to connectedGroup5 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedGroup4 : ConnectedDataStream to connectedGroup4 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedGroup3 : ConnectedDataStream to connectedGroup3 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedGroup2 : ConnectedDataStream to connectedGroup2 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedPartition5 : ConnectedDataStream to connectedPartition5 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type coIt : ConnectedIterativeDataStream<Integer,String> to coIt : ConnectedIterativeDataStreams<Integer,String> in method public testCoIteration() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type connectedGroup1 : ConnectedDataStream to connectedGroup1 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connectedSource : ConnectedDataStream<Integer,Integer> to connectedSource : ConnectedStreams<Integer,Integer> in method public testOutputTypeConfigurationWithTwoInputTransformation() : void in class org.apache.flink.streaming.api.graph.StreamGraphGeneratorTest |
From |
To |
|
Change Variable Type connectedPartition3 : ConnectedDataStream to connectedPartition3 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connect : ConnectedDataStream<Integer,Integer> to connect : ConnectedStreams<Integer,Integer> in method public operatorTest() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connected : ConnectedDataStream to connected : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type coIter : ConnectedIterativeDataStream<Integer,Integer> to coIter : ConnectedIterativeDataStreams<Integer,Integer> in method public testCoIterClosingFromOutOfLoop() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type connectedPartition1 : ConnectedDataStream to connectedPartition1 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type iter2 : ConnectedIterativeDataStream<Integer,String> to iter2 : ConnectedIterativeDataStreams<Integer,String> in method public testImmutabilityWithCoiteration() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type connectedPartition4 : ConnectedDataStream to connectedPartition4 : ConnectedStreams in method public testPartitioning() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |