From 3e6771a3514d3a677bffdb48ad7db1bbf5c21aa5 Mon Sep 17 00:00:00 2001 From: Luke Sikina Date: Fri, 14 Jun 2024 11:32:46 -0400 Subject: [PATCH] [ALS-6265] Add any record of multi support to time series processor --- .../hpds/processing/timeseries/TimeseriesProcessor.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/timeseries/TimeseriesProcessor.java b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/timeseries/TimeseriesProcessor.java index c0a6b9b0..66911893 100644 --- a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/timeseries/TimeseriesProcessor.java +++ b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/timeseries/TimeseriesProcessor.java @@ -3,6 +3,7 @@ import java.io.FileNotFoundException; import java.io.IOException; import java.util.*; +import java.util.stream.Collectors; import edu.harvard.hms.dbmi.avillach.hpds.processing.AbstractProcessor; import edu.harvard.hms.dbmi.avillach.hpds.processing.AsyncResult; @@ -94,6 +95,7 @@ private void exportTimeData(Query query, AsyncResult result, TreeSet id //get a list of all fields mentioned in the query; export all data associated with any included field List pathList = new LinkedList(); pathList.addAll(query.getAnyRecordOf()); + pathList.addAll(query.getAnyRecordOfMulti().stream().flatMap(Collection::stream).collect(Collectors.toList())); pathList.addAll(query.getFields()); pathList.addAll(query.getRequiredFields()); pathList.addAll(query.getCategoryFilters().keySet());