2016-08-07 2 views
0

JeremyChandraとして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

答えて

0

に1から番号を生成します。私はRStudio内からrmr2をインストールしましたが、mapreduce関数が正常に実行されたように見えても、何らかの形でスクリプトが利用できませんでした。私は、ログの1つでは、rmr2が見つからなかったことに驚きましたが、スクリプトはまだ私に_SUCCESSを与えました!

私は最終的にR(sudo Rを使って)にrmr2 freshをインストールし、必要なパッケージreshape2とcaToolsをインストールしました。

関連する問題