flink快速入門？

Flink 是由Apache軟件基金會(huì)開(kāi)發(fā)的開(kāi)源流處理框架，其核心是用Java和Scala編寫(xiě)的分布式流數(shù)據(jù)流引擎。

Flink以數(shù)據(jù)并行和流水線方式執(zhí)行任意流數(shù)據(jù)程序，F(xiàn)link的流水線運(yùn)行時(shí)系統(tǒng)可以執(zhí)行批處理和流處理程序。此外，F(xiàn)link的運(yùn)行時(shí)本身也支持迭代算法的執(zhí)行。

Flink程序在執(zhí)行后被映射到流數(shù)據(jù)流，每個(gè)Flink數(shù)據(jù)流以一個(gè)或多個(gè)源（數(shù)據(jù)輸入，例如消息隊(duì)列或文件系統(tǒng)）開(kāi)始，并以一個(gè)或多個(gè)接收器（數(shù)據(jù)輸出，如消息隊(duì)列、文件系統(tǒng)或數(shù)據(jù)庫(kù)等）結(jié)束。Flink可以對(duì)流執(zhí)行任意數(shù)量的變換，這些流可以被編排為有向無(wú)環(huán)數(shù)據(jù)流圖，允許應(yīng)用程序分支和合并數(shù)據(jù)流。