Flink的DataSet基本算子总结( 三 )

(table2.f0,null,table2.f1);}else{return new Tuple3(table2.f0,table1.f1,table2.f1);}} }).print();System.out.println("***********************************");//全外连接table1.fullOuterJoin(table2).where(0).equalTo(0).with(new JoinFunction, Tuple2, Tuple3>() { public Tuple3 join(Tuple2 table1, Tuple2 table2)throws Exception {if(table1 == null){return new Tuple3(table2.f0,null,table2.f1);}else if(table2 == null){return new Tuple3(table1.f0,table1.f1,null);}else{return new Tuple3(table1.f0,table1.f1,table2.f1);} } }).print();【Flink的DataSet基本算子总结】更多的教程也会继续更新 , 不清楚的地方 , 也可以给我留言!