@@ -176,11 +176,13 @@ yoy_fn <- function(x){
176176
177177
178178
179- full_dbi <- create_full_dbi(x ) | >
180- dplyr :: select(- c(year ))
179+ full_dbi <- create_full_dbi(x )
180+ # dplyr::select(-c(year))
181181
182182 # create lag
183- lag_dbi <- full_dbi | >
183+ lag_dbi <-
184+ full_dbi | >
185+ dplyr :: select(- c(year )) | >
184186 dbplyr :: window_order(date ,!!! x @ datum @ group_quo ) | >
185187 dplyr :: mutate(
186188 date_lag = dplyr :: lead(date ,n = !! x @ fn @ lag_n )
@@ -192,18 +194,16 @@ yoy_fn <- function(x){
192194 dplyr :: select(- c(date ,!! x @ value @ value_quo ,missing_date_indicator ))
193195
194196 # bring tables together
195- out_dbi <- dplyr :: left_join(
197+ out_dbi <-
198+ dplyr :: left_join(
196199 full_dbi
197200 ,lag_dbi
198201 ,by = dplyr :: join_by(date == date_lag ,!!! x @ datum @ group_quo )
199202 ) | >
200- dplyr :: mutate(
201- year = lubridate :: year(date )
202- ,.after = date
203- ) | >
204203 dplyr :: relocate(date ,year ) | >
205204 dplyr :: relocate(dplyr :: any_of(" missing_date_indicator" ),.after = dplyr :: last_col())
206205
206+
207207 return (out_dbi )
208208
209209}
@@ -429,11 +429,11 @@ qoq_fn <- function(x){
429429 # create calendar
430430 # full_dbi <- fpaR::create_calendar(x)
431431
432- full_dbi <- create_full_dbi(x ) | >
433- dplyr :: select(- c(year ,quarter ))
432+ full_dbi <- create_full_dbi(x )
434433
435434 # create lag
436435 lag_dbi <- full_dbi | >
436+ dplyr :: select(- c(year ,quarter )) | >
437437 dbplyr :: window_order(date ,!!! x @ datum @ group_quo ) | >
438438 dplyr :: mutate(
439439 date_lag = dplyr :: lead(date ,n = !! x @ fn @ lag_n )
@@ -448,10 +448,6 @@ qoq_fn <- function(x){
448448 ,lag_dbi
449449 ,by = dplyr :: join_by(date == date_lag ,!!! x @ datum @ group_quo )
450450 ) | >
451- dplyr :: mutate(
452- year = lubridate :: year(date )
453- ,quarter = lubridate :: quarter(date )
454- ) | >
455451 dplyr :: relocate(date ,year ,quarter ) | >
456452 dplyr :: relocate(dplyr :: any_of(" missing_date_indicator" ),.after = dplyr :: last_col())
457453
@@ -680,14 +676,12 @@ mom_fn <- function(x){
680676
681677 # full_dbi <- create_calendar(x)
682678
683- full_dbi <- create_full_dbi(x ) | >
684- dplyr :: select(
685- - c(year ,month )
686- )
679+ full_dbi <- create_full_dbi(x )
687680
688681
689682 # create lag
690683 lag_dbi <- full_dbi | >
684+ dplyr :: select(- c(year ,month )) | >
691685 dbplyr :: window_order(date ,!!! x @ datum @ group_quo ) | >
692686 dplyr :: mutate(
693687 date_lag = dplyr :: lead(date ,n = !! x @ fn @ lag_n )
@@ -706,11 +700,6 @@ mom_fn <- function(x){
706700 ,lag_dbi
707701 ,by = dplyr :: join_by(date == date_lag ,!!! x @ datum @ group_quo )
708702 ) | >
709- dplyr :: mutate(
710- year = lubridate :: year(date )
711- ,month = lubridate :: month(date )
712- ,.after = date
713- ) | >
714703 dplyr :: relocate(date ,year ,month ) | >
715704 dplyr :: relocate(dplyr :: any_of(" missing_date_indicator" ),.after = dplyr :: last_col())
716705
@@ -952,12 +941,10 @@ wow_fn <- function(x){
952941
953942
954943
955- full_dbi <- create_full_dbi(x ) | >
956- dplyr :: select(
957- - c(year ,month ,week )
958- )
944+ full_dbi <- create_full_dbi(x )
959945
960946 lag_dbi <- full_dbi | >
947+ dplyr :: select(- c(year ,month ,week )) | >
961948 dbplyr :: window_order(date ) | >
962949 dplyr :: mutate(
963950 date_lag = dplyr :: lead(date ,n = !! x @ fn @ lag_n )
@@ -973,11 +960,6 @@ wow_fn <- function(x){
973960 ,lag_dbi
974961 ,by = dplyr :: join_by(date == date_lag ,!!! x @ datum @ group_quo )
975962 ) | >
976- dplyr :: mutate(
977- year = lubridate :: year(date )
978- ,month = lubridate :: month(date )
979- ,week = dplyr :: sql(" DATE_PART('week',date)" )
980- ) | >
981963 dplyr :: relocate(date ,year ,month ,week ) | >
982964 dplyr :: relocate(dplyr :: any_of(" missing_date_indicator" ),.after = dplyr :: last_col())
983965
0 commit comments