RHIPE simple Example ...error

21 views
Skip to first unread message

김종훈

unread,
Jan 25, 2016, 11:57:27 AM1/25/16
to rhipe
> 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..

Jeremiah Rounds

unread,
Jan 25, 2016, 1:02:50 PM1/25/16
to rhipe
rhmr() was depreciated and then removed.  Use rhwatch() instead.  It is rhmr() with more functionality and more organized monitoring of MapReduce jobs.  It basically starts and watches jobs for you.
Reply all
Reply to author
Forward
0 new messages