【零基礎學flink】flink DataStream API 詳解

Flink中的DataStream主要用於實現數據流的轉換操做（例如，過濾，更新狀態，定義窗口，聚合）。最初能夠從各類源（例如，消息隊列，套接字流，文件）建立數據流（DataStream）。結果經過sink返回，sink操做主要有：將數據寫入文件、標準輸出（例如命令行終端）。Flink程序能夠在各類環境中運行，獨立運行或嵌入其餘程序中。執行能夠在本地JVM中執行，也能夠在許多計算機集羣上執行。ht

>>阅读原文<<