Apache Flink - groupBy

Question

私はhttp://dataartisans.github.io/flink-training/exercises/の最初の練習に従おうとしています。

次の問題が発生しました。 groupBy関数は私に何を返すのですか？そして、foldLeftメソッドはそれをどう変換しますか？

コードは、以下である：

mails.map { 
      m => (m._1.substring(0, 7), m._2.substring(m._2.lastIndexOf("<") + 1, m._2.length - 1)) 
     } 
     .groupBy(0, 1) 
     .reduceGroup(ms => ms.foldLeft("", "", 0)((c, m) => (m._1, m._2, c._3 + 1))) 

よろしく、

ケビン

Answer 1

groupBy戻るグループ化されたデータセット：https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/dataset_transformations.html#groupreduce-on-grouped-dataset

foldLeftはフォールディング（または還元）順序を定義します。参照：https://en.wikipedia.org/wiki/Fold_%28higher-order_function%29