X-Git-Url: https://git.auder.net/?p=talweg.git;a=blobdiff_plain;f=pkg%2FR%2FgetData.R;h=153a660f35a56667342232331fdad2c8992b8f97;hp=4f9e179a56378a858c148a76d95a0631484658dd;hb=1e20780ee1505fac6c7ed68d340892c497524561;hpb=fa8078f9658dccadc0f9bcc7b54c13ecda621816 diff --git a/pkg/R/getData.R b/pkg/R/getData.R index 4f9e179..153a660 100644 --- a/pkg/R/getData.R +++ b/pkg/R/getData.R @@ -18,8 +18,8 @@ #' @return An object of class Data #' #' @export -getData = function(ts_data, exo_data, - input_tz="GMT", date_format="%d/%m/%Y %H:%M", working_tz="GMT", predict_at=0) +getData = function(ts_data, exo_data, input_tz="GMT", date_format="%d/%m/%Y %H:%M", + working_tz="GMT", predict_at=0, limit=Inf) { # Sanity checks (not full, but sufficient at this stage) if (!is.character(input_tz) || !is.character(working_tz)) @@ -73,26 +73,18 @@ getData = function(ts_data, exo_data, break } -##TODO: fix note comment ! --> triche: exo contient les mesures du jour, pas forcément toutes available - # NOTE: if predict_at does not cut days at midnight, - # for the exogenous to be synchronized they need to be shifted - if (predict_at > 0) - { - exo_hat = as.data.frame(exo_df[max(1,i-1),(1+nb_exos+1):(1+2*nb_exos)]) - exo = as.data.frame(exo_df[max(1,i-1),2:(1+nb_exos)]) - } - else - { - exo_hat = as.data.frame(exo_df[i,(1+nb_exos+1):(1+2*nb_exos)]) - exo = as.data.frame(exo_df[i,2:(1+nb_exos)]) - } - i = i + 1 - #center data + # NOTE: if predict_at does not cut days at midnight, exogenous vars need to be shifted + exo_hat = as.data.frame( exo_df[ + ifelse(predict_at>0,max(1,i-1),i) , (1+nb_exos+1):(1+2*nb_exos) ] ) + exo = as.data.frame( exo_df[ ifelse(predict_at>0,max(1,i-1),i) , 2:(1+nb_exos) ] ) level = mean(serie, na.rm=TRUE) centered_serie = serie - level -# data$append(time, centered_serie, level, exo_hat, exo_Jm1) #TODO: slow: why ? + #data$append(time, centered_serie, level, exo_hat, exo_Jm1) #too slow; TODO: use R6 class data[[length(data)+1]] = list("time"=time, "serie"=centered_serie, "level"=level, "exo_hat"=exo_hat, "exo"=exo) + if (i >= limit) + break + i = i + 1 } new("Data",data=data) }