最新回答 / 慕工程3537235
應(yīng)該是Java8 lambda+匿名內(nèi)部類 語法?
最贊回答 / 無概念
它們都支持流式計(jì)算，F(xiàn)ink是一行一行處理，是基于操作符的連續(xù)流模型，而Spark是基于數(shù)據(jù)片集合(RDD)進(jìn)行小批量處理，所以Spark在流式處理方面會(huì)增加一些延遲。Flink可以支持毫秒級(jí)計(jì)算，而Spark則只能支持秒級(jí)計(jì)算。如果是要求對(duì)實(shí)時(shí)性要求非常高的場(chǎng)景(如高頻實(shí)時(shí)交易)，Spark是難以滿足的，可以考慮Flink或Storm。
2020-10-28
最贊回答 / 莊學(xué)爸
好吧，自問自答，懂了。視頻上說sliding size為5s，其實(shí)就是每隔5s計(jì)算一次最近30s出現(xiàn)的數(shù)據(jù)，那么肯定數(shù)據(jù)是會(huì)重疊的，因?yàn)榛瑒?dòng)窗口之間的時(shí)間線會(huì)有重疊。?
2020-06-27
最新回答 / weixin_慕娘1232888
用啊，我們都是用Scala開發(fā)的，只不過有人不會(huì)Scala
最新回答 / MOVBV
Linux也行。
最新回答 / qq_ODJ_0
電腦性能問題，再加上flink本身是大數(shù)據(jù)處理框架，你數(shù)據(jù)量小的時(shí)候，根本發(fā)揮不出flink的能力。
2019-08-13
最新回答 / 慕沐1067312
去Apache.flink.org官網(wǎng)下載，代碼是自動(dòng)生成的
最新回答 / 帝國大學(xué)
嗯優(yōu)秀
最新回答 / FreeLoop_z
<...code...>
講師回答 / 大數(shù)據(jù)技術(shù)與架構(gòu)
你好，我才看到你的留言。這個(gè)問題比較可能是因?yàn)椋耗氵@個(gè)類中import的是不是StreamExecutionEnvironment，或者看看Tuple2是不是引用對(duì)了。