From c047a4a1db1552a64c53e88d4c7960f53571eebf Mon Sep 17 00:00:00 2001 From: Erik de Vries Date: Wed, 29 May 2019 19:25:56 +0200 Subject: [PATCH] aggregator_elastic: explicit reference to aggregator function --- R/aggregator_elastic.R | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/R/aggregator_elastic.R b/R/aggregator_elastic.R index 9884f88..1c6d887 100644 --- a/R/aggregator_elastic.R +++ b/R/aggregator_elastic.R @@ -31,7 +31,7 @@ aggregator_elastic <- function(out, localhost = F, actorids, ver, cores, es_supe filter(ids1 %in% actorids) agg_party_actors <- bind_rows(mclapply(unique(actor_df$`_id`), - aggregator, + mamlr:::aggregator, actor_df = actor_df, merge_id = paste0(actor$`_source.partyId`,'_mfsa'), mc.cores = cores)) @@ -39,7 +39,7 @@ aggregator_elastic <- function(out, localhost = F, actorids, ver, cores, es_supe party <- actor_df %>% filter(!endsWith(ids1, '_a')) agg_party <- bind_rows(mclapply(unique(party$`_id`), - aggregator, + mamlr:::aggregator, actor_df = party, merge_id = paste0(actor$`_source.partyId`,'_mfs'), mc.cores = cores)) @@ -47,7 +47,7 @@ aggregator_elastic <- function(out, localhost = F, actorids, ver, cores, es_supe actors_only <- actor_df %>% filter(endsWith(ids1, '_a')) agg_actors <- bind_rows(mclapply(unique(actors_only$`_id`), - aggregator, + mamlr:::aggregator, actor_df = actors_only, merge_id = paste0(actor$`_source.partyId`,'_ma'), mc.cores = cores))