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