On Apr 29, 2013, at 11:16 AM, Kaiyin Zhong (Victor Chung) wrote: > Hi, Uwe. > > I still don't get how this can be done correctly. Here is what I tried. > > In the file funcs.R, define these functions: > > library('modeest') > x = vector(length=500) > x = sapply(x, function(i) i=sample(c(1,0), 1)) > pastK = function(n, x, k) { > if (n>k) { return(x[(n-k):(n-1)]) } > else {return(NA)} > } > predR = function(x, k) { > pastList = lapply(1:length(x), function(n) pastK(n, x, k)) > pred = sapply(pastList, function(v) mfv(v)[1]) > ratio = sum(pred==x, na.rm=T)/(length(pred) - sum(is.na(pred))) > } > > > > Then do the following: > > library('snow') > cl = makeCluster(rep('localhost', 12), 'SOCK') > clusterSetupRNG(cl) > clusterEvalQ(cl, 'source("funcs.R")')
Are you sure those outer single quote marks are not the problem? -- David. > testK = function() { > k = seq(3, 25, 2) > r = parSapply(cl, k, function(i) predR(x, i)) > print(r) > } > testK() > stopCluster(cl) > > > The error still pops up: > > Error in checkForRemoteErrors(val) : > 12 nodes produced errors; first error: could not find function "predR" > > > > > > Best regards, > > Kaiyin ZHONG > ------------------------------ > FMB, Erasmus MC > k.zh...@erasmusmc.nl > kindlych...@gmail.com > > > On Tue, Apr 23, 2013 at 3:44 PM, Uwe Ligges <lig...@statistik.tu-dortmund.de >> wrote: > >> >> >> On 23.04.2013 15:00, Kaiyin Zhong (Victor Chung) wrote: >> >>> Thanks for the reply. >>> >>> How can i make the functions known to all nodes? >>> >> >> See ?clusterEvalQ >> >> you may also want to try the parallel packages. >> >> Best, >> Uwe Ligges >> >> >> >> >>> Best regards, >>> >>> Kaiyin ZHONG >>> ------------------------------**------------------------------** >>> ------------ >>> FMB, Erasmus MC >>> k.zh...@erasmusmc.nl <mailto:k.zh...@erasmusmc.nl> >>> kindlych...@gmail.com <mailto:kindlych...@gmail.com> >>> >>> >>> >>> On Tue, Apr 23, 2013 at 2:43 PM, Uwe Ligges >>> <lig...@statistik.tu-dortmund.**de <lig...@statistik.tu-dortmund.de> >>> <mailto:lig...@statistik.tu-**dortmund.de<lig...@statistik.tu-dortmund.de>>> >>> wrote: >>> >>> >>> >>> On 18.04.2013 11:11, Kaiyin Zhong (Victor Chung) wrote: >>> >>> Here is the code, assuming 8 cores in the cpu. >>> >>> library('modeest') >>> library('snow') >>> >>> cl = makeCluster(rep('localhost', 8), 'SOCK') >>> x = vector(length=50) >>> x = sapply(x, function(i) i=sample(c(1,0), 1)) >>> >>> pastK = function(n, x, k) { >>> if (n>k) { return(x[(n-k):(n-1)]) } >>> else {return(NA)} >>> } >>> >>> predR = function(x, k) { >>> pastList = lapply(1:length(x), function(n) pastK(n, x, k)) >>> pred = sapply(pastList, function(v) mfv(v)[1]) >>> ratio = sum(pred==x, na.rm=T)/(length(pred) - sum(is.na >>> <http://is.na>(pred))) >>> >>> } >>> >>> testK = function() { >>> k = seq(3, 25, 2) >>> r = parSapply(cl, k, function(i) predR(x, i)) >>> # r = sapply(k, function(i) predR(x, i)) >>> } >>> >>> r = testK() >>> stopCluster(cl) >>> >>> Here is the error: >>> Error in checkForRemoteErrors(val) : >>> 8 nodes produced errors; first error: could not find >>> function "predR" >>> >>> >>> >>> predR is not yet known on all nodes, just on the master. You have to >>> tell the nodes about the definition first. >>> >>> Best, >>> Uwe Ligges >>> >>> >>> >>> >>> >>> >>> Best regards, >>> >>> Kaiyin ZHONG >>> ------------------------------ >>> >>> FMB, Erasmus MC >>> k.zh...@erasmusmc.nl <mailto:k.zh...@erasmusmc.nl> >>> kindlych...@gmail.com <mailto:kindlych...@gmail.com> >>> >>> [[alternative HTML version deleted]] >>> >>> ______________________________**__________________ >>> R-help@r-project.org <mailto:R-help@r-project.org> mailing list >>> >>> https://stat.ethz.ch/mailman/_**_listinfo/r-help<https://stat.ethz.ch/mailman/__listinfo/r-help> >>> >>> >>> <https://stat.ethz.ch/mailman/**listinfo/r-help<https://stat.ethz.ch/mailman/listinfo/r-help> >>>> >>> PLEASE do read the posting guide >>> >>> http://www.R-project.org/__**posting-guide.html<http://www.R-project.org/__posting-guide.html> >>> >>> >>> <http://www.R-project.org/**posting-guide.html<http://www.R-project.org/posting-guide.html> >>>> >>> and provide commented, minimal, self-contained, reproducible code. >>> >>> >>> > > [[alternative HTML version deleted]] > > ______________________________________________ > R-help@r-project.org mailing list > https://stat.ethz.ch/mailman/listinfo/r-help > PLEASE do read the posting guide http://www.R-project.org/posting-guide.html > and provide commented, minimal, self-contained, reproducible code. David Winsemius Alameda, CA, USA ______________________________________________ R-help@r-project.org mailing list https://stat.ethz.ch/mailman/listinfo/r-help PLEASE do read the posting guide http://www.R-project.org/posting-guide.html and provide commented, minimal, self-contained, reproducible code.