JeremyとChandraとしてCloudera Quickstart 5.7.0でRにrmr2をインストールしました。私は[チャンドラ]あたり単純MapReduceのプログラムを試してみました:
small.ints <- to.dfs(1:1000)
out <- mapreduce(input = small.ints, map = function(k, v) keyval(v, v^2))
df <- as.data.frame(from.dfs(out))
とDFの出力は、次のとおり
data frame with 0 columns and 0 rows
とfrom.dfs(OUT)を示す:
$key
NULL
$val
NULL
他
[Jeremy]と[Chandra]の例もmapreduceが生成された/ tmpディレクトリに_SUCCESSを表示していますが、同じ出力を生成しています。助言がありますか?
to.dfsとfrom.dfsは正常に動作しているようです。私が試した:
small.ints <- to.dfs(1:1000)
out <- from.dfs(small.ints)
out
を、これは私が今これを考え出し1000