MapReduceジョブのキーと値の一連のペアを出力します。
使用上の注意
この関数は、hadoop.exec
およびhadoop.run
の引数mapper
、reducer
またはcombiner
でのみ使用できます。orch.keyvals
関数はORCH
クライアントのAPIで公開されないため、他のどこからも呼び出すことができません。
例
次のコード・フラグメントでは、orch.keyval
を使用してマッパー関数を作成し、orch.keyvals
を使用してリデューサ関数を作成します。
hadoop.run(data, mapper(k,v) { if (v$value > 10) { orch.keyval(k, v) } else { NULL } }, reducer(k,vals) { orch.keyvals(k,vals) } )
次のコード・フラグメントは、前述の例のorch.keyvals
と同じリデュース操作を実行する、for
ループ内のorch.keyval
を示しています。
reducer(k,vals) { out <- list() for (v in vals) { out <- list(out, orch.keyval(k,vals)) } out }