?

代碼如下:

import org.apache.flink.api.scala._ import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.apache.flink.streaming.api.windowing.assigners.GlobalWindows import org.apache.flink.streaming.api.windowing.triggers.CountTrigger;val person = senv.fromElements(("1","小張"),("2","小劉"),("3","小力"),("4","小心")) val money = senv.fromElements(("1",100),("2",200),("3",300))?person.join(money).where(_._1).equalTo(_._1).window(GlobalWindows.create()).trigger(CountTrigger.of(2)).apply((x,y)=>{println( x+"==="+y)}).print()senv.execute()

實驗結果:
(1,小張)===(1,100)
1> ()
(2,小劉)===(2,200)
1> ()
(3,小力)===(3,300)
1> ()

?

沒有輸出結果的原因:

trigger(CountTrigger.of(2))沒寫

?

來自張云云．

?

總結

以上是生活随笔為你收集整理的flink的datastream进行join操作没有输出结果一例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。