From 75623856f763e4aba7309c50b165c63edbd25f4a Mon Sep 17 00:00:00 2001 From: Erik de Vries Date: Thu, 25 Apr 2019 16:57:57 +0200 Subject: [PATCH] elasticizer: updated scroll_clear to use conn object --- R/elasticizer.R | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/R/elasticizer.R b/R/elasticizer.R index 36cf8ea..02271f9 100644 --- a/R/elasticizer.R +++ b/R/elasticizer.R @@ -19,7 +19,6 @@ ################################################################################################# #################################### Get data from ElasticSearch ################################ ################################################################################################# -### Just a bogus comment elasticizer <- function(query, src = T, index = 'maml', es_pwd = .rs.askForPassword("Elasticsearch READ"), batch_size = 1024, max_batch = Inf, time_scroll = "5m", update = NULL, localhost = F, ...){ retries <- 10 ### Number of retries on error sleep <- 30 ### Number of seconds between retries @@ -133,10 +132,10 @@ elasticizer <- function(query, src = T, index = 'maml', es_pwd = .rs.askForPassw } } if (length(update) > 0) { - scroll_clear(x = json$`_scroll_id`) + scroll_clear(conn = conn, x = json$`_scroll_id`) return("Done updating") } else { - scroll_clear(x = json$`_scroll_id`) + scroll_clear(conn = conn, x = json$`_scroll_id`) return(out) } }