Flink DataStream API編程

DataStream API Flink 的DataStream程序四實現數據流轉換的常規程序(例如L過濾, 更新狀態,定義窗口,聚合).最初從各類源（例如，消息隊列，套接字流，文件）建立數據流。結果經過接收器返回，接收器能夠例如將數據寫入文件或標準輸出（例如命令行終端）。Flink程序能夠在各類環境中運行，獨立運行或嵌入其餘程序中。執行能夠在本地JVM中執行，也能夠在許多計算機的集羣上執行。ja

>>阅读原文<<