|
Rename Method public invoke(collector Collector<OUT>) : void renamed to public run(collector Collector<OUT>) : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource |
From |
To |
|
Rename Method public invoke(collector Collector<Tuple4<Integer,Integer,Double,Long>>) : void renamed to public run(collector Collector<Tuple4<Integer,Integer,Double,Long>>) : void in class org.apache.flink.streaming.examples.windowing.TopSpeedWindowingExample.CarSource |
From |
To |
|
Rename Method public invoke(collector Collector<Integer>) : void renamed to public run(collector Collector<Integer>) : void in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.NewDataSource |
From |
To |
|
Rename Method public invoke(out Collector<Tuple2<String,Integer>>) : void renamed to public run(out Collector<Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.examples.join.WindowJoin.SalarySource |
From |
To |
|
Rename Method public invoke(collector Collector<T>) : void renamed to public run(collector Collector<T>) : void in class org.apache.flink.streaming.api.function.source.FromElementsFunction |
From |
To |
|
Rename Method public invoke(collector Collector<OUT>) : void renamed to public run(collector Collector<OUT>) : void in class org.apache.flink.streaming.connectors.kafka.api.KafkaSource |
From |
To |
|
Rename Method public invoke(collector Collector<OUT>) : void renamed to public run(collector Collector<OUT>) : void in class org.apache.flink.streaming.api.function.source.SourceFunction |
From |
To |
|
Rename Method public invoke(collector Collector<Tuple3<String,Long,Long>>) : void renamed to public run(collector Collector<Tuple3<String,Long,Long>>) : void in class org.apache.flink.streaming.api.function.source.FileMonitoringFunction |
From |
To |
|
Rename Method public invoke(collector Collector<StockPrice>) : void renamed to public run(collector Collector<StockPrice>) : void in class org.apache.flink.streaming.examples.windowing.StockPrices.StockSource |
From |
To |
|
Rename Method public close() : void renamed to public cancel() : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource |
From |
To |
|
Rename Method public invoke(collector Collector<String>) : void renamed to public run(collector Collector<String>) : void in class org.apache.flink.streaming.examples.windowing.StockPrices.TweetSource |
From |
To |
|
Rename Method public invoke(collector Collector<String>) : void renamed to public run(collector Collector<String>) : void in class org.apache.flink.streaming.api.function.source.SocketTextStreamFunction |
From |
To |
|
Rename Method public invoke(collector Collector<Long>) : void renamed to public run(collector Collector<Long>) : void in class org.apache.flink.streaming.api.function.source.GenSequenceFunction |
From |
To |
|
Rename Method public invoke(collector Collector<OUT>) : void renamed to public run(collector Collector<OUT>) : void in class org.apache.flink.streaming.connectors.flume.FlumeSource |
From |
To |
|
Rename Method public invoke(collector Collector<String>) : void renamed to public run(collector Collector<String>) : void in class org.apache.flink.streaming.connectors.twitter.TwitterSource |
From |
To |
|
Rename Method public invoke(collector Collector<String>) : void renamed to public run(collector Collector<String>) : void in class org.apache.flink.streaming.api.function.source.FileSourceFunction |
From |
To |
|
Rename Method public invoke(out Collector<Tuple2<String,Integer>>) : void renamed to public run(out Collector<Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.examples.join.WindowJoin.GradeSource |
From |
To |
|
Rename Method public invoke(collector Collector<Tuple1<Integer>>) : void renamed to public run(collector Collector<Tuple1<Integer>>) : void in class org.apache.flink.streaming.api.streamvertex.StreamVertexTest.MySource |
From |
To |
|
Rename Method public invoke(collector Collector<Integer>) : void renamed to public run(collector Collector<Integer>) : void in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.TrainingDataSource |
From |
To |