> rhinit()
Rhipe: Using Rhipe.jar file
Initializing Rhipe v0.74.2
Initializing mapfile caches
Map = expression({
word = unlist(strsplit(unlist(map.values)," "))
word_table = table(word)
tname = names(word_table)
for(i in 1:length(tname))
rhcollect(tname[i], word_table[i])
})
Reduce = expression(
pre = { total = 0 },
reduce = {total = sum(total, unlist(reduce.values))},
post = { rhcollect(reduce.key, total) }
)
Reduce = expression(
pre = { total = 0 },
reduce = {total = sum(total, unlist(reduce.values))},
post = { rhcollect(reduce.key, total) }
)
Error in rhmr() :
STOP! Do not call rhmr, call rhwatch with the same arguments you would have done with rhmr
The first uses RHIVE.
An error in applying a simple example
Why?
Please..