junos
/
rapids
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Start preparing the true usernames CSV file.

labels
junos 2021-12-01 11:29:22 +01:00
parent 0be4cd5a8f
commit 22f9e0722d
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/data/streams/aware_postgresql/container.R
View File

@ -121,7 +121,7 @@ pull_participants_ids <- function(stream_parameters, usernames, participants_con
filter(username %in% usernames) %>% filter(username %in% usernames) %>%
select(username, id) select(username, id)
message(paste0("Executing the following query to get the participant's id: \n", sql_render(query_participant_id))) message(paste0("Executing the following query to get participants' IDs: \n", sql_render(query_participant_id)))
participant_data <- query_participant_id %>% collect() participant_data <- query_participant_id %>% collect()
@ -149,7 +149,13 @@ pull_participants_device_ids <- function(stream_parameters, participants_ids, de
group_by(participant_id) %>% group_by(participant_id) %>%
distinct(device_id, .keep_all = FALSE) distinct(device_id, .keep_all = FALSE)
message(paste0("Executing the following query to get the distinct device IDs: \n", sql_render(query_device_id))) message(
paste0(
"Executing the following query to get the distinct device IDs: \n",
sql_render(query_device_id),
"\n NOTE: This might take a long time."
)
)
device_ids <- query_device_id %>% collect() device_ids <- query_device_id %>% collect()