search for: sfstop

...}) my_calc <- calculator$new() wrapper <- function(x) {my_calc$do_calc(x)} # STANZA 2: use snowfall without wrapper -- WORKING #sfInit(parallel=TRUE, cpus=2, type="SOCK") #sfExport("calculator") #sfExport("my_calc") #results <- sfLapply(1:10,my_calc$do_calc) #sfStop() #print(results) # STANZA 3: use snowfall with wrapper -- NOT WORKING # (not working by itself, but does work if the previous stanza is run first!!) sfInit(parallel=TRUE, cpus=2, type="SOCK") sfExport("calculator") sfExport("my_calc") sfExport("wrapper") l...

...13 14 15 16 17 18 19 20 0.02380952 0.01984127 0.07936508 0.02380952 0.01984127 0.01190476 0.02777778 0.02380952 0.01984127 0.01190476 0.02380952 0.01984127 0.02380952 0.02380952 0.01984127 0.02380952 0.01984127 0.02380952 0.02380952 0.02777778 > sfStop() DOESN'T WORK: 3) > sfInit( parallel=TRUE, cpus=4 ); > sfApply(dNiftyOpt,1,getTimeToMaturity) #Added the time to maturity. DOESN'T WORK? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 > sfStop(); My d...

Dear all, I am trying to execute the simple example in snowfall http://cran.r-project.org/web/packages/snowfall/vignettes/snowfall.pdf ... require(snow) require(snowfall) sfInit( parallel=TRUE, cpus=2 ) sfLapply( 1:10, exp ) sfStop() I have installed the snow and snowfall packages in R on a machine with windows xp, however, after running the "sfInit( parallel=TRUE, cpus=2 )" line I get an error ... Error in system("whoami", intern = TRUE, ignore.stderr = TRUE) : whoami not found Error in paste(sep = &q...

...ction(y2, y3) { new('dogg', bb=c(y2, 'GA'), cc = f1(y3)) } dat <- 1:5 f1(dat) f3('NY', dat) sapply(c("state1", 'state2', 'state3'), f3, dat) sfExportAll() sfClusterEval(ls()) sfSapply(c("s1", 's2', 's3'), f3, dat) sfStop() # sfSapply generates the following error # Error in checkForRemoteErrors(val) : # 2 nodes produced errors; first error: "dogg" is not a defined class === end ============= -- View this message in context: http://r.789695.n4.nabble.com/undefined-S4-class-in-parallel-computing...

...n, 0.02, 0.54) logx <- log(x) sfExport("logx") # Compute fake function computeTakens <- function(r0idx) { if(r0idx == 1) return(NA) return(1/(logx[r0idx] - sum(logx[1:(r0idx-1)])/(r0idx-1))) } res <- sfClusterApplyLB(n:1, computeTakens) } sfStop() -- Ing. Mario Valle Data Analysis and Visualization Group | http://www.cscs.ch/~mvalle Swiss National Supercomputing Centre (CSCS) | Tel: +41 (91) 610.82.60 v. Cantonale Galleria 2, 6928 Manno, Switzerland | Fax: +41 (91) 610.82.82

...Terminated R --no-save $* --- script ------------------------------------ library('Rmpi') library('snowfall') sfInit(parallel=TRUE, cpus=3, type="MPI") for(i in 1:9) { n <- 20000 logx <- runif(n, 0.02, 0.54) sfExport("logx") } sfStop() -- Ing. Mario Valle Data Analysis and Visualization Group | http://www.cscs.ch/~mvalle Swiss National Supercomputing Centre (CSCS) | Tel: +41 (91) 610.82.60 v. Cantonale Galleria 2, 6928 Manno, Switzerland | Fax: +41 (91) 610.82.82 ___________________________________________...

.......) { } else { if (class(ob1)=="SpatialCollections") { ob2 <- ob1 at lineobj } else if (class(ob1)=="SpatialLines") { ob2 <- ob1 } ob3 <- data.frame(length_m=sapply(1:length(ob2), function(l) gLength(ob2 [l, ]))) ..... } ..... } sfStop() The problem is that the code returns the error message: Error in checkForRemoteErrors(val) : one node produced an error: object 'ob2' not found >From the debugging function "sfCat", I also get these warning messages: Warning messages: 1: In searchCommandline(par...

R-helpers: What would be the absolute fastest way to make a large "empty" file (e.g. filled with all zeroes) on disk, given a byte size and a given number number of empty values. I know I can use writeBin, but the "object" in this case may be far too large to store in main memory. I'm asking because I'm going to use this file in conjunction with mmap to do parallel

Merry Xmas to all, I am writing a function and curiously this runs sometimes on one data set and fails on another and i cannot figure out why. Any help much appreciated. If i run the code below with data <- iris[ ,1:4] The code runs fine, but if i run on a large dataset i get the following error (showing data structures as matrix is large) > str(cluster.data) num [1:9985, 1:811] 0 0 0 0

...en el segundo cluster se lanzara t2 de la lista tarea de forma paralela print(paste("Tiempo transcurrido",round(difftime(Sys.time(),hora.ini,units="hours" ),digits = 2) , "horas")) #Una vez finalizada la inserción informamos del tiempo que hemos tardado sfStop() #Detenemos los dos cluster Un saludo José Luis Gilsanz Gómez Estadística Tasaciones Hipotecarias María de Molina, 54 - 28006 - Madrid Tel. : 34-914549694 Fax : 34-917822164 Email : jluis.gilsanz en tasacionesh.com Site web: www.tasacionesh.es -- AVISO LEGAL -- Los datos pers...