?

代碼如下:

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()

實(shí)驗(yàn)結(jié)果:
(1,小張)===(1,100)
1> ()
(2,小劉)===(2,200)
1> ()
(3,小力)===(3,300)
1> ()

?

沒(méi)有輸出結(jié)果的原因:

trigger(CountTrigger.of(2))沒(méi)寫(xiě)

?

來(lái)自張?jiān)圃?#xff0e;

?

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。