3.1.2　流應用程序實現

Flink程序的基本構建塊是stream和transformation（流和轉換）。從概念上講，stream是數據記錄的流（可能永遠不會結束），transformation是一個運算，它接收一個或多個流作為輸入，經過處理／計算后生成一個或多個輸出流。

下面實現一個完整的可工作的Flink流應用程序示例。

【示例3-1】　將有關人員的記錄流作為輸入，并從中篩選出未成年人信息。

Scala代碼如下：

（1）在IntelliJ IDEA中創建一個Flink項目，使用flink-quickstart-scala項目模板（Flink項目的創建過程可參考2.2節）。

（2）設置依賴。在pom.xml文件中添加以下依賴內容：

（3）創建主程序StreamingJobDemo1，編輯流處理代碼如下：

執行以上代碼，輸出結果如下：

Java代碼如下：

（1）在IntelliJ IDEA中創建一個Flink項目，使用flink-quickstart-Java項目模板（Flink項目的創建過程可參考2.2節）。

（2）設置依賴。在pom.xml文件中添加以下依賴內容：

（3）創建一個POJO類，用來表示流中的數據，代碼如下：

（4）打開項目中的StreamingJob對象文件，編輯流處理代碼如下：

（5）執行以上程序，輸出結果如下。