Flink中與sparkPairFunction對(duì)應(yīng)的是什么？Flink是一個(gè)類似于spark的開源技術(shù)棧，因?yàn)樗€提供批處理、流式計(jì)算、圖形計(jì)算、交互式查詢、機(jī)器學(xué)習(xí)等功能。Flink也是內(nèi)存計(jì)算，

Flink中與sparkPairFunction對(duì)應(yīng)的是什么？

Flink是一個(gè)類似于spark的開源技術(shù)棧，因?yàn)樗€提供批處理、流式計(jì)算、圖形計(jì)算、交互式查詢、機(jī)器學(xué)習(xí)等功能。Flink也是內(nèi)存計(jì)算，與spark類似，但不同的是spark的計(jì)算模型是基于RDD的，即流式計(jì)算作為一種特殊的批處理，其數(shù)據(jù)流實(shí)際上是RDD。而Flink把批處理看作是一種特殊的流計(jì)算，而批處理和流計(jì)算的引擎是兩個(gè)：抽象數(shù)據(jù)集和數(shù)據(jù)流。弗林克的表演也很好。流計(jì)算的時(shí)延小于spark，可以實(shí)現(xiàn)真正的流計(jì)算，而spark只能是準(zhǔn)流計(jì)算。此外，在批處理中，當(dāng)?shù)螖?shù)增加時(shí)，F(xiàn)link的速度比spark快。因此，如果Flink出現(xiàn)得更早，它可能會(huì)比spark更受歡迎。

開發(fā)Flink應(yīng)用選擇Java還是Scala？

根據(jù)個(gè)人編程習(xí)慣，可以使用Java和scala。