train.mr <-mapreduce (
train.hdfs,
map = function (k, v) {
keyval (k, v$item)
},
reduce = function (k, v) {
m <-merge (v, v)
keyval (m$x, m$y)
}
)
from.dfs(train.mr)
如果我尝试执行上述类型的代码,我将得到
$key
NULL
$val
NULL
输出是在rhadoop中的一个目录“/tmp/file”中生成的,但是我无法使用from.dfs(“/tmp/file”)检索如果我提到backend=“local”,我将得到输出,但是如果我给出backend=“hadoop”,我将得到key和value的空值。
暂无答案!
目前还没有任何答案,快来回答吧!