|
Change Parameter Type ctx : SourceContext<Tuple2<String,Integer>> to ctx : SourceContext<Tuple3<Long,String,Integer>> in method public run(ctx SourceContext<Tuple3<Long,String,Integer>>) : void in class org.apache.flink.streaming.examples.join.WindowJoin.SalarySource |
From |
To |
|
Change Parameter Type second : Tuple2<String,Integer> to second : Tuple3<Long,String,Integer> in method public join(first Tuple3<Long,String,Integer>, second Tuple3<Long,String,Integer>) : Tuple3<String,Integer,Integer> in class org.apache.flink.streaming.examples.join.WindowJoin.MyJoinFunction |
From |
To |
|
Change Parameter Type first : Tuple2<String,Integer> to first : Tuple3<Long,String,Integer> in method public join(first Tuple3<Long,String,Integer>, second Tuple3<Long,String,Integer>) : Tuple3<String,Integer,Integer> in class org.apache.flink.streaming.examples.join.WindowJoin.MyJoinFunction |
From |
To |
|
Change Parameter Type ctx : SourceContext<Tuple2<String,Integer>> to ctx : SourceContext<Tuple3<Long,String,Integer>> in method public run(ctx SourceContext<Tuple3<Long,String,Integer>>) : void in class org.apache.flink.streaming.examples.join.WindowJoin.GradeSource |
From |
To |
|
Change Return Type void to Tuple2<DataStream<Tuple3<Long,String,Integer>>,DataStream<Tuple3<Long,String,Integer>>> in method private getInputStreams(env StreamExecutionEnvironment) : Tuple2<DataStream<Tuple3<Long,String,Integer>>,DataStream<Tuple3<Long,String,Integer>>> in class org.apache.flink.streaming.examples.join.WindowJoin |
From |
To |
|
Change Return Type Tuple2<String,Integer> to Tuple3<Long,String,Integer> in method public map(line String) : Tuple3<Long,String,Integer> in class org.apache.flink.streaming.examples.join.WindowJoin.MySourceMap |
From |
To |