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