2016-07-11 15 views
0

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

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

Antwort

Verwandte Themen