AfwHS Fold

Asakusa FrameworkをScalaで記述するAfwHS α版のFoldについて。

概要

Foldは、データの畳み込みを行うもの。
集約キー毎に要素（データ）同士を演算（集計など）して1つにまとめる。

Summarizedは、集計を行って別のデータモデルを出力する。
Foldは同じデータモデル内で集計を行い、そのデータモデルを返す。

Foldの使用方法

s0.fold(名前, キー) { 処理 }

↓AsakusaFW

@Fold
public void 名前(キー left, right){ 処理 }

この“処理”（関数）は、AsakusaFW（Hadoop）で実際にMapReduceが動く際に呼ばれる。

Foldの使用例

import scala.collection.JavaFolders._

import jp.hishidama.afwhs._

//モデルクラスとそのラッパークラスと暗黙変換をインポート
import afws.wordcount.modelgen.dmdl.model.WordCountModel
import afws.wordcount.modelgen.dmdl.model.WordCountModelWrapper
import afws.wordcount.modelgen.dmdl.model.WordCountModelImplicit._

val sum = words.fold("sum3", "word") {
  (left, right) =>
    val wl = left.asScala
    val wr = right.asScala
    wl.count += wr.count
}

@Fold
public void sum3(@Key(group={"word"}) WordCountModel left, WordCountModel right) {
  left.setCount(left.getCount() + right.getCount());
}