diff --git a/src/data/streams/aware_postgresql/format.yaml b/src/data/streams/aware_postgresql/format.yaml index cbd983a4..24bdff5f 100644 --- a/src/data/streams/aware_postgresql/format.yaml +++ b/src/data/streams/aware_postgresql/format.yaml @@ -72,7 +72,7 @@ PHONE_APPLICATIONS_FOREGROUND: MUTATION: COLUMN_MAPPINGS: SCRIPTS: - - src/data/streams/mutations/phone/straw/app_add_name.py + - src/data/streams/mutations/phone/straw/app_add_name.R PHONE_APPLICATIONS_NOTIFICATIONS: ANDROID: @@ -86,7 +86,7 @@ PHONE_APPLICATIONS_NOTIFICATIONS: MUTATION: COLUMN_MAPPINGS: SCRIPTS: - - src/data/streams/mutations/phone/straw/app_add_name.py + - src/data/streams/mutations/phone/straw/app_add_name.R PHONE_BATTERY: ANDROID: diff --git a/src/data/streams/mutations/phone/straw/app_add_name.R b/src/data/streams/mutations/phone/straw/app_add_name.R new file mode 100644 index 00000000..c3222e80 --- /dev/null +++ b/src/data/streams/mutations/phone/straw/app_add_name.R @@ -0,0 +1,8 @@ +source("renv/activate.R") # needed to use RAPIDS renv environment +library(dplyr) + +main <- function(data, stream_parameters){ + data <- data %>% + mutate(application_name = "hashed") + return(data) +}