|
Change Return Type IterativeDataStream<T> to IterativeStream<T> in method public iterate() : IterativeStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type ConnectedIterativeDataStreams<T,F> to ConnectedIterativeStreams<T,F> in method public withFeedbackType(feedbackTypeString String) : ConnectedIterativeStreams<T,F> in class org.apache.flink.streaming.api.datastream.IterativeStream |
From |
To |
|
Change Return Type ConnectedIterativeDataStreams<T,F> to ConnectedIterativeStreams<T,F> in method public withFeedbackType(feedbackType TypeInformation<F>) : ConnectedIterativeStreams<T,F> in class org.apache.flink.streaming.api.datastream.IterativeStream |
From |
To |
|
Change Return Type IterativeDataStream<T> to IterativeStream<T> in method public iterate(maxWaitTimeMillis long) : IterativeStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type ConnectedIterativeDataStreams<T,F> to ConnectedIterativeStreams<T,F> in method public withFeedbackType(feedbackTypeClass Class<F>) : ConnectedIterativeStreams<T,F> in class org.apache.flink.streaming.api.datastream.IterativeStream |
From |
To |
|
Change Variable Type iteration : IterativeDataStream<Boolean> to iteration : IterativeStream<Boolean> in method public testWithCheckPointing() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type coIt : ConnectedIterativeDataStreams<Integer,String> to coIt : ConnectedIterativeStreams<Integer,String> in method public testCoIteration() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testExecutionWithEmptyIteration() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter2 : ConnectedIterativeDataStreams<Integer,String> to iter2 : ConnectedIterativeStreams<Integer,String> in method public testImmutabilityWithCoiteration() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter2 : IterativeDataStream<Integer> to iter2 : IterativeStream<Integer> in method public testClosingFromOutOfLoop() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type it : IterativeDataStream<Tuple5<Integer,Integer,Integer,Integer,Integer>> to it : IterativeStream<Tuple5<Integer,Integer,Integer,Integer,Integer>> in method public main(args String[]) : void in class org.apache.flink.streaming.examples.iteration.IterateExample |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testImmutabilityWithCoiteration() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testIncorrectParallelism() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iteration : IterativeDataStream<Boolean> to iteration : IterativeStream<Boolean> in method public testSimpleIteration() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testClosingFromOutOfLoop() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testDoubleClosing() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type it : IterativeDataStream<Tuple2<Long,Tuple2<String,Long>>> to it : IterativeStream<Tuple2<Long,Tuple2<String,Long>>> in method public complexIntegrationTest1() : void in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testmultipleHeadsTailsSimple() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type coIter : ConnectedIterativeDataStreams<Integer,Integer> to coIter : ConnectedIterativeStreams<Integer,Integer> in method public testCoDifferingParallelism() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testCoIterClosingFromOutOfLoop() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testDifferingParallelism() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type it : IterativeDataStream<Integer> to it : IterativeStream<Integer> in method public testGroupByFeedback() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type coIter : ConnectedIterativeDataStreams<Integer,Integer> to coIter : ConnectedIterativeStreams<Integer,Integer> in method public testCoIterClosingFromOutOfLoop() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type iter1 : IterativeDataStream<Integer> to iter1 : IterativeStream<Integer> in method public testmultipleHeadsTailsWithTailPartitioning() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |