3.3.2　flatMap轉換

這也是很常用的一個轉換操作。flatMap接收一條記錄并輸出0條、一條或多條記錄。關于flatMap轉換的簡單介紹見表3-2。

在下面的示例中演示了如何應用flatMap轉換。

Scala代碼如下：

Java代碼如下：

在上面的代碼中，flatMap（）函數的傳入參數是一個Lambda表達式，它對于flatMap（）的支持是無法猜測出來類型的，必須通過returns（Types.STRING）指定具體的返回值類型。

或者，也可以像下面這樣，使用匿名內部類（而不是Lambda表達式），代碼如下：

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