Apache Flink - groupBy

Question

Ich versuche, die erste Übung auf http://dataartisans.github.io/flink-training/exercises/ zu folgen.

Jetzt komme ich zu dem folgenden Problem. Was gibt mir die groupBy Funktion zurück? Und wie transformiert die foldLeft Methode das - für mich unbekannte - Ergebnis?

The code ist die folgender:

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))) 

Regards, Kevin

Answer 1

groupBy returns grouped Daten set: https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/dataset_transformations.html#groupreduce-on-grouped-dataset

foldLeft defines die folding (oder reducing) order. Siehe hier: https://en.wikipedia.org/wiki/Fold_%28higher-order_function%29