|
Change Variable Type splitSource : SplitDataStream to splitSource : SplitStream in method public createTopology() : FlinkTopology in class org.apache.flink.stormcompatibility.api.FlinkTopologyBuilder |
From |
To |
|
Change Variable Type splitStream : SplitDataStream<SplitStreamType<Integer>> to splitStream : SplitStream<SplitStreamType<Integer>> in method public main(args String[]) : void in class org.apache.flink.stormcompatibility.split.SpoutSplitExample |
From |
To |
|
Change Variable Type step : SplitDataStream<Tuple2<Long,Tuple2<String,Long>>> to step : SplitStream<Tuple2<Long,Tuple2<String,Long>>> in method public complexIntegrationTest1() : void in class org.apache.flink.streaming.api.complex.ComplexIntegrationTest |
From |
To |
|
Change Variable Type source3 : SplitDataStream<Integer> to source3 : SplitStream<Integer> in method public testmultipleHeadsTailsSimple() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type source3 : SplitDataStream<Integer> to source3 : SplitStream<Integer> in method public testmultipleHeadsTailsWithTailPartitioning() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type split : SplitDataStream<Integer> to split : SplitStream<Integer> in method public operatorTest() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type source : SplitDataStream<Long> to source : SplitStream<Long> in method public outputSelectorTest() : void in class org.apache.flink.streaming.api.collector.DirectedOutputTest |
From |
To |
|
Change Variable Type splitStreams : SplitDataStream to splitStreams : SplitStream in method public createTopology() : FlinkTopology in class org.apache.flink.stormcompatibility.api.FlinkTopologyBuilder |
From |
To |
|
Change Variable Type step : SplitDataStream<Tuple5<Integer,Integer,Integer,Integer,Integer>> to step : SplitStream<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 splittedResult : SplitDataStream<Tuple2<Integer,Integer>> to splittedResult : SplitStream<Tuple2<Integer,Integer>> in method public testFoldOperation() : void in class org.apache.flink.streaming.api.StreamingOperatorsITCase |
From |
To |