cleaning - fix getSimilarDaysIndices ; to finish

[talweg.git] / pkg / R / computeForecast.R

diff --git a/pkg/R/computeForecast.R b/pkg/R/computeForecast.R
index 3537e8a..bd19b8d 100644 (file)
--- a/pkg/R/computeForecast.R
+++ b/pkg/R/computeForecast.R
@@ -59,14 +59,26 @@ computeForecast = function(data, indices, forecaster, pjump,
 #oo = forecaster$predictSerie(data, integer_indices[1], memory, horizon, ...)
 #browser()
 
-       library(parallel)
-       ppp <- parallel::mclapply(seq_along(integer_indices), function(i) {
-               list(
-                       "forecast" = forecaster$predictSerie(data, integer_indices[i], memory, horizon, ...),
-                       "params"= forecaster$getParameters(),
-                       "index" = integer_indices[i] )
-               }, mc.cores=3)
-
+       parll=TRUE #FALSE
+       if (parll)
+       {
+               library(parallel)
+               ppp <- parallel::mclapply(seq_along(integer_indices), function(i) {
+                       list(
+                               "forecast" = forecaster$predictSerie(data, integer_indices[i], memory, horizon, ...),
+                               "params"= forecaster$getParameters(),
+                               "index" = integer_indices[i] )
+                       }, mc.cores=3)
+       }
+       else
+       {
+               ppp <- lapply(seq_along(integer_indices), function(i) {
+                       list(
+                               "forecast" = forecaster$predictSerie(data, integer_indices[i], memory, horizon, ...),
+                               "params"= forecaster$getParameters(),
+                               "index" = integer_indices[i] )
+                       })
+       }
 #browser()
 
 for (i in seq_along(integer_indices))