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
}