make it possible to render any combination of plots

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/AggreateInternal.java

@@ -1,5 +0,0 @@
-package org.lucares.pdb.plot.api;
-
-public enum AggreateInternal {
-NONE, MEAN, PERCENTILE95, PERCENTILE99, PERCENTILE999
-}

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/Aggregate.java

@@ -1,11 +1,9 @@
-package org.lucares.pdbui.domain;
+package org.lucares.pdb.plot.api;
 
 /**
  * Note: The order in this enum defines the order in which the aggregates are drawn.
  */
 public enum Aggregate {
-	NONE,
-
 	PARALLEL,
 	
 	SCATTER,

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/AggregateHandler.java

@@ -2,12 +2,14 @@ package org.lucares.pdb.plot.api;
 
 import java.nio.file.Path;
 import java.util.Collection;
+import java.util.Optional;
 
 import org.lucares.recommind.logs.DataSeries;
+import org.lucares.recommind.logs.LineStyle;
 
 public interface AggregateHandler {
-
-	// TODO handle aggregates as normal DataSeries
+  
+  Aggregate getAggregateType();
 
 	void addGnuplotDefinitions(StringBuilder result, String separator, Collection<DataSeries> dataSeries);
 
@@ -18,10 +20,17 @@ public interface AggregateHandler {
 	default void appendfln(final StringBuilder builder, final String format, final Object... args) {
 		builder.append(String.format(format + "\n", args));
 	}
+	
+	default String gnuplotTitle(Optional<String> title) {
+	  
+	  return title.isPresent() ? "title '"+title.get()+"'": "notitle";
+	}
 
-	void addPlotsBeforeScatter(StringBuilder result, Collection<DataSeries> dataSeries);
-
-	void addPlotsAfterScatter(StringBuilder result, Collection<DataSeries> dataSeries);
+//	void addPlotsBeforeScatter(StringBuilder result, Collection<DataSeries> dataSeries);
+//
+//	void addPlotsAfterScatter(StringBuilder result, Collection<DataSeries> dataSeries);
+	
+	void addPlot(StringBuilder result, AggregatedData aggregatedData, LineStyle lineStyle, Optional<String> title);
 
 	CustomAggregator createCustomAggregator(Path tmpDir, PlotSettings plotSettings, long fromEpochMilli, long toEpochMilli);
 

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/AggregateHandlerCollection.java

@@ -0,0 +1,64 @@
+package org.lucares.pdb.plot.api;
+
+import java.nio.file.Path;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Optional;
+
+import org.lucares.recommind.logs.DataSeries;
+
+public class AggregateHandlerCollection {
+  private static final Comparator<AggregateHandler> COMPARATOR = Comparator.comparing(AggregateHandler::getAggregateType);
+  
+  private final List<AggregateHandler> aggregateHandlers = new ArrayList<>();
+
+  public void add(AggregateHandler aggregateHandler) {
+    aggregateHandlers.add(aggregateHandler);
+    Collections.sort(aggregateHandlers, COMPARATOR);
+  }
+
+  public void addGnuplotDefinitions(StringBuilder result, String datafileSeparator, Collection<DataSeries> dataSeries) {
+    for (AggregateHandler handler : aggregateHandlers) {
+      handler.addGnuplotDefinitions(result, datafileSeparator, dataSeries);
+    }
+  }
+
+  public AggregatorCollection createCustomAggregator(Path tmpDir, PlotSettings plotSettings, long fromEpochMilli,
+      long toEpochMilli) {
+
+    final List<CustomAggregator> aggregators = new ArrayList<>();
+
+    for (AggregateHandler handler : aggregateHandlers) {
+      CustomAggregator aggregator = handler.createCustomAggregator(tmpDir, plotSettings, fromEpochMilli, toEpochMilli);
+      if (aggregator != null) {
+        aggregators.add(aggregator);
+      }
+    }
+
+    return new AggregatorCollection(aggregators);
+  }
+
+  public void addPlots(StringBuilder result, Collection<DataSeries> dataSeries) {
+
+    boolean first = true;
+    for (AggregateHandler handler : aggregateHandlers) {
+
+      for (DataSeries dataSerie : dataSeries) {
+        final Optional<String> title = first ? Optional.of(dataSerie.getTitle()) : Optional.empty();
+
+        Optional<AggregatedData> aggregatedData = dataSerie.getAggregatedData().get(handler.getAggregateType());
+        if(aggregatedData.isPresent()) {
+          handler.addPlot(result, aggregatedData.get(), dataSerie.getStyle(), title);
+        }
+      }
+
+      first = false;
+
+    }
+
+  }
+
+}

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/AggregatedDataCollection.java

@@ -0,0 +1,22 @@
+package org.lucares.pdb.plot.api;
+
+import java.util.Iterator;
+import java.util.LinkedHashMap;
+import java.util.Optional;
+
+public class AggregatedDataCollection implements Iterable<AggregatedData>{
+  private final LinkedHashMap<Aggregate, AggregatedData> aggregatedDatas = new LinkedHashMap<>();
+
+  public void put(Aggregate aggregate, AggregatedData aggregatedData) {
+    aggregatedDatas.put(aggregate, aggregatedData);
+  }
+
+  @Override
+  public Iterator<AggregatedData> iterator() {
+    return aggregatedDatas.values().iterator();
+  }
+
+  public Optional<AggregatedData> get(Aggregate aggregateType) {
+    return Optional.ofNullable(aggregatedDatas.get(aggregateType));
+  }
+}

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/AggregatorCollection.java

@@ -0,0 +1,29 @@
+package org.lucares.pdb.plot.api;
+
+import java.io.IOException;
+import java.util.List;
+
+public class AggregatorCollection {
+  private final List<CustomAggregator> aggregators;
+
+  public AggregatorCollection(List<CustomAggregator> aggregators) {
+    this.aggregators = aggregators;
+  }
+
+  public void addValue(boolean valueIsInYRange, long epochMilli, long value) {
+    for (CustomAggregator aggregator : aggregators) {
+      aggregator.addValue(valueIsInYRange, epochMilli, value);
+    }
+  }
+
+  public AggregatedDataCollection getAggregatedData() throws IOException {
+    
+    AggregatedDataCollection result = new AggregatedDataCollection();
+    
+    for (CustomAggregator aggregator : aggregators) {
+      result.put(aggregator.getType(), aggregator.getAggregatedData());
+    }
+    
+    return result;
+  }
+}

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/CumulativeDistributionCustomAggregator.java

@@ -120,4 +120,9 @@ public class CumulativeDistributionCustomAggregator implements CustomAggregator
 		return new AggregatedData(title, dataFile);
 	}
 
+  @Override
+  public Aggregate getType() {
+    return Aggregate.CUM_DISTRIBUTION;
+  }
+
 }

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/CumulativeDistributionHandler.java

@@ -2,49 +2,44 @@ package org.lucares.pdb.plot.api;
 
 import java.nio.file.Path;
 import java.util.Collection;
+import java.util.Optional;
 
 import org.lucares.recommind.logs.DataSeries;
 import org.lucares.recommind.logs.LineStyle;
 
 public class CumulativeDistributionHandler implements AggregateHandler {
 
-	@Override
-	public CustomAggregator createCustomAggregator(final Path tmpDir, PlotSettings plotSettings, final long fromEpochMilli,
-			final long toEpochMilli) {
-		return new CumulativeDistributionCustomAggregator(tmpDir);
-	}
+  @Override
+  public CustomAggregator createCustomAggregator(final Path tmpDir, PlotSettings plotSettings,
+      final long fromEpochMilli, final long toEpochMilli) {
+    return new CumulativeDistributionCustomAggregator(tmpDir);
+  }
 
-	public CumulativeDistributionHandler() {
-	}
+  public CumulativeDistributionHandler() {
+  }
 
-	@Override
-	public void addGnuplotDefinitions(final StringBuilder result, final String separator,
-			final Collection<DataSeries> dataSeries) {
+  @Override
+  public void addGnuplotDefinitions(final StringBuilder result, final String separator,
+      final Collection<DataSeries> dataSeries) {
 
-		appendln(result, "set x2label \"Cumulative Distribution\"");
-		appendln(result, "set format x2 \"%.0f%%\"");
-		appendln(result, "set x2tics 5");
-		appendln(result, "set x2range [\"0\":\"100\"]");
-	}
+    appendln(result, "set x2label \"Cumulative Distribution\"");
+    appendln(result, "set format x2 \"%.0f%%\"");
+    appendln(result, "set x2tics 5");
+    appendln(result, "set x2range [\"0\":\"100\"]");
+  }
 
-	@Override
-	public void addPlotsBeforeScatter(final StringBuilder result, final Collection<DataSeries> dataSeries) {
-		// nothing to do: the percentile line should be drawn on the scatter plots and
-		// must therefore be rendered after the scatter
-	}
+  @Override
+  public void addPlot(StringBuilder result, AggregatedData aggregatedData, LineStyle lineStyle, Optional<String> title) {
+    appendfln(result, "'%s' using 1:2 %s with lines axes x2y1 lw 2 %s, \\", //
+        aggregatedData.getDataFile().getAbsolutePath(), //
+        gnuplotTitle(title),//
+        lineStyle.darker()//
+    );
+  }
 
-	@Override
-	public void addPlotsAfterScatter(final StringBuilder result, final Collection<DataSeries> dataSeries) {
-		for (final DataSeries dataSerie : dataSeries) {
-			final AggregatedData aggregatedData = dataSerie.getAggregatedData();
-			if (aggregatedData != null) {
-				final LineStyle lineStyle = dataSerie.getStyle();
-				appendfln(result, "'%s' using 1:2 notitle with lines axes x2y1 lw 2 %s, \\", //
-						aggregatedData.getDataFile().getAbsolutePath(), //
-						lineStyle.darker()//
-				);
-			}
-		}
-	}
+  @Override
+  public Aggregate getAggregateType() {
+    return Aggregate.CUM_DISTRIBUTION;
+  }
 
 }

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/CustomAggregator.java

@@ -7,4 +7,6 @@ public interface CustomAggregator {
   void addValue(boolean valueIsInYRange, long epochMilli, long value);
 
   AggregatedData getAggregatedData() throws IOException;
+
+  Aggregate getType();
 }

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/NullAggregate.java

@@ -1,32 +0,0 @@
-package org.lucares.pdb.plot.api;
-
-import java.nio.file.Path;
-import java.util.Collection;
-
-import org.lucares.recommind.logs.DataSeries;
-
-public class NullAggregate implements AggregateHandler {
-
-	@Override
-	public void addGnuplotDefinitions(final StringBuilder result, final String separator,
-			final Collection<DataSeries> dataSeries) {
-		// nothing to do; this is a Null-Object
-	}
-
-	@Override
-	public void addPlotsBeforeScatter(final StringBuilder result, final Collection<DataSeries> dataSeries) {
-		// nothing to do; this is a Null-Object
-	}
-
-	@Override
-	public void addPlotsAfterScatter(final StringBuilder result, final Collection<DataSeries> dataSeries) {
-		// nothing to do; this is a Null-Object
-	}
-
-	@Override
-	public CustomAggregator createCustomAggregator(final Path tmpDir, PlotSettings plotSettings, final long fromEpochMilli,
-			final long toEpochMilli) {
-		return new NullCustomAggregator();
-	}
-
-}

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/NullCustomAggregator.java

@@ -1,16 +0,0 @@
-package org.lucares.pdb.plot.api;
-
-public class NullCustomAggregator implements CustomAggregator {
-
-	@Override
-	public void addValue(boolean valueIsInYRange,final long epochMilli, final long value) {
-		// nothing to do; this is a null-object
-
-	}
-
-	@Override
-	public AggregatedData getAggregatedData() {
-		return null;
-	}
-
-}

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregate.java

@@ -2,45 +2,43 @@ package org.lucares.pdb.plot.api;
 
 import java.nio.file.Path;
 import java.util.Collection;
+import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 
 import org.lucares.recommind.logs.DataSeries;
+import org.lucares.recommind.logs.LineStyle;
 
 public class ParallelRequestsAggregate implements AggregateHandler {
 
-	@Override
-	public void addGnuplotDefinitions(final StringBuilder result, final String separator,
-			final Collection<DataSeries> dataSeries) {
-		appendln(result, "set y2label \"Parallel Requests\"");
-		appendln(result, "set y2tics");
-	}
+  @Override
+  public void addGnuplotDefinitions(final StringBuilder result, final String separator,
+      final Collection<DataSeries> dataSeries) {
+    appendln(result, "set y2label \"Parallel Requests\"");
+    appendln(result, "set y2tics");
+  }
 
-	@Override
-	public void addPlotsBeforeScatter(final StringBuilder result, final Collection<DataSeries> dataSeries) {
-		for (final DataSeries dataSerie : dataSeries) {
-			final AggregatedData aggregatedData = dataSerie.getAggregatedData();
-			if (aggregatedData != null) {
-				appendfln(result, "'%s' using 1:2 notitle with filledcurve axes x1y2 lw 1 %s, \\", //
-						aggregatedData.getDataFile().getAbsolutePath(), //
-						dataSerie.getStyle().brighter().asGnuplotLineStyle()//
-				);
-			}
-		}
-	}
+  @Override
+  public void addPlot(StringBuilder result, AggregatedData aggregatedData, LineStyle lineStyle,
+      Optional<String> title) {
+    appendfln(result, "'%s' using 1:2 %s with filledcurve axes x1y2 lw 1 %s, \\", //
+        aggregatedData.getDataFile().getAbsolutePath(), //
+        gnuplotTitle(title), //
+        lineStyle.brighter().asGnuplotLineStyle()//
+    );
+  }
 
-	@Override
-	public void addPlotsAfterScatter(final StringBuilder result, final Collection<DataSeries> dataSeries) {
-		// nothing to do: the parallel line plots shall be drawn below the scatter plot,
-		// so that you can see both. Therefore it must be drawn first.
-	}
+  @Override
+  public CustomAggregator createCustomAggregator(final Path tmpDir, PlotSettings plotSettings,
+      final long fromEpochMilli, final long toEpochMilli) {
+    if ((toEpochMilli - fromEpochMilli) <= TimeUnit.HOURS.toMillis(50)) {
+      return new ParallelRequestsAggregator(tmpDir, fromEpochMilli, toEpochMilli);
+    } else {
+      return null;
+    }
+  }
 
-	@Override
-	public CustomAggregator createCustomAggregator(final Path tmpDir, PlotSettings plotSettings, final long fromEpochMilli,
-			final long toEpochMilli) {
-		if ((toEpochMilli - fromEpochMilli) <= TimeUnit.HOURS.toMillis(5)) {
-			return new ParallelRequestsAggregator(tmpDir, fromEpochMilli, toEpochMilli);
-		} else {
-			return new NullCustomAggregator();
-		}
-	}
+  @Override
+  public Aggregate getAggregateType() {
+    return Aggregate.PARALLEL;
+  }
 }

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ParallelRequestsAggregator.java

@@ -93,4 +93,9 @@ public class ParallelRequestsAggregator implements CustomAggregator {
 		builder.append(NEWLINE);
 	}
 
+  @Override
+  public Aggregate getType() {
+    return Aggregate.PARALLEL;
+  }
+
 }

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/PlotSettings.java

@@ -34,7 +34,7 @@ public class PlotSettings {
 
 	private AxisScale yAxisScale;
 
-	private AggregateHandler aggregate;
+	private AggregateHandlerCollection aggregates;
 
 	private int yRangeMin;
 	private int yRangeMax;
@@ -141,17 +141,17 @@ public class PlotSettings {
 		return "PlotSettings [query=" + query + ", height=" + height + ", width=" + width + ", thumbnailMaxWidth="
 				+ thumbnailMaxWidth + ", thumbnailMaxHeight=" + thumbnailMaxHeight + ", groupBy=" + groupBy
 				+ ", limitBy=" + limitBy + ", limit=" + limit + ", dateRangeAsString=" + dateRangeAsString
-				+ ", yAxisScale=" + yAxisScale + ", aggregate=" + aggregate + ", yRangeMin=" + yRangeMin
+				+ ", yAxisScale=" + yAxisScale + ", aggregates=" + aggregates + ", yRangeMin=" + yRangeMin
 				+ ", yRangeMax=" + yRangeMax + ", yRangeUnit=" + yRangeUnit + ", keyOutside=" + keyOutside
 				+ ", generateThumbnail=" + generateThumbnail + "]";
 	}
 
-	public void setAggregate(final AggregateHandler aggregate) {
-		this.aggregate = aggregate;
+	public void setAggregates(final AggregateHandlerCollection aggregates) {
+		this.aggregates = aggregates;
 	}
 
-	public AggregateHandler getAggregate() {
-		return aggregate;
+	public AggregateHandlerCollection getAggregates() {
+		return aggregates;
 	}
 
 	public void setKeyOutside(final boolean keyOutside) {

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ScatterAggregateHandler.java

@@ -2,9 +2,11 @@ package org.lucares.pdb.plot.api;
 
 import java.nio.file.Path;
 import java.util.Collection;
+import java.util.Optional;
 
 import org.lucares.recommind.logs.DataSeries;
 import org.lucares.recommind.logs.GnuplotLineType;
+import org.lucares.recommind.logs.LineStyle;
 
 public class ScatterAggregateHandler implements AggregateHandler {
 
@@ -13,29 +15,16 @@ public class ScatterAggregateHandler implements AggregateHandler {
     // TODO Auto-generated method stub
 
   }
-
+  
   @Override
-  public void addPlotsBeforeScatter(StringBuilder result, Collection<DataSeries> dataSeries) {
-
-    for (final DataSeries dataSerie : dataSeries) {
-      final AggregatedData aggregatedData = dataSerie.getAggregatedData();
-      if (aggregatedData != null) {
-
-        appendfln(result, "'%s' using 1:2 title '%s' with %s %s, \\", //
-            aggregatedData.getDataFile(), //
-            dataSerie.getTitle(), //
-            GnuplotLineType.Points,
-            dataSerie.getStyle()//
-        );
-      }
-    }
-
-  }
-
-  @Override
-  public void addPlotsAfterScatter(StringBuilder result, Collection<DataSeries> dataSeries) {
-    // TODO Auto-generated method stub
-
+  public void addPlot(StringBuilder result, AggregatedData aggregatedData, LineStyle lineStyle, Optional<String> title) {
+    
+    appendfln(result, "'%s' using 1:2 %s with %s %s, \\", //
+        aggregatedData.getDataFile(), //
+        gnuplotTitle(title), //
+        GnuplotLineType.Points, //
+        lineStyle//
+    );
   }
 
   @Override
@@ -44,4 +33,9 @@ public class ScatterAggregateHandler implements AggregateHandler {
 
     return new ScatterAggregator(tmpDir, plotSettings, fromEpochMilli, toEpochMilli);
   }
+
+  @Override
+  public Aggregate getAggregateType() {
+    return Aggregate.SCATTER;
+  }
 }

pdb-plotting/src/main/java/org/lucares/pdb/plot/api/ScatterAggregator.java

@@ -91,4 +91,9 @@ public class ScatterAggregator implements CustomAggregator {
 
     return new AggregatedData("scatter", dataFile);
   }
+
+  @Override
+  public Aggregate getType() {
+    return Aggregate.SCATTER;
+  }
 }

pdb-plotting/src/main/java/org/lucares/recommind/logs/CsvSummary.java

@@ -1,16 +1,16 @@
 package org.lucares.recommind.logs;
 
-import org.lucares.pdb.plot.api.AggregatedData;
+import org.lucares.pdb.plot.api.AggregatedDataCollection;
 
 class CsvSummary {
 	private final int values;
 	private final long maxValue;
-	private final AggregatedData aggregatedData;
+	private final AggregatedDataCollection aggregatedData;
 	private final double statsAverage;
 	private final int plottedValues;
 
 	public CsvSummary(final int values, final int plottedValues, final long maxValue,
-			final double statsAverage, final AggregatedData aggregatedData) {
+			final double statsAverage, final AggregatedDataCollection aggregatedData) {
 		super();
 		this.values = values;
 		this.plottedValues = plottedValues;
@@ -48,7 +48,7 @@ class CsvSummary {
 		return statsAverage;
 	}
 
-	public AggregatedData getAggregatedData() {
+	public AggregatedDataCollection getAggregatedData() {
 		return aggregatedData;
 	}
 }

pdb-plotting/src/main/java/org/lucares/recommind/logs/DataSeries.java

@@ -6,7 +6,7 @@ import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 
-import org.lucares.pdb.plot.api.AggregatedData;
+import org.lucares.pdb.plot.api.AggregatedDataCollection;
 import org.lucares.pdb.plot.api.Limit;
 
 public interface DataSeries {
@@ -41,7 +41,7 @@ public interface DataSeries {
 
 	public LineStyle getStyle();
 
-	public AggregatedData getAggregatedData();
+	public AggregatedDataCollection getAggregatedData();
 
 	public static Map<String, Integer> toMap(final List<DataSeries> dataSeries) {
 		final Map<String, Integer> result = new LinkedHashMap<>();

pdb-plotting/src/main/java/org/lucares/recommind/logs/FileBackedDataSeries.java

@@ -1,6 +1,6 @@
 package org.lucares.recommind.logs;
 
-import org.lucares.pdb.plot.api.AggregatedData;
+import org.lucares.pdb.plot.api.AggregatedDataCollection;
 
 public class FileBackedDataSeries implements DataSeries {
 
@@ -66,7 +66,7 @@ public class FileBackedDataSeries implements DataSeries {
 	}
 
 	@Override
-	public AggregatedData getAggregatedData() {
+	public AggregatedDataCollection getAggregatedData() {
 		return csvSummary.getAggregatedData();
 	}
 }

pdb-plotting/src/main/java/org/lucares/recommind/logs/GnuplotFileGenerator.java

@@ -27,7 +27,7 @@ public class GnuplotFileGenerator {
 
 		appendfln(result, "set datafile separator \"%s\"", settings.getDatafileSeparator());
 
-		settings.getAggregate().addGnuplotDefinitions(result, settings.getDatafileSeparator(), dataSeries);
+		settings.getAggregates().addGnuplotDefinitions(result, settings.getDatafileSeparator(), dataSeries);
 
 		appendfln(result, "set timefmt '%s'", settings.getTimefmt());
 
@@ -103,10 +103,8 @@ public class GnuplotFileGenerator {
 
 		appendf(result, "plot ");
 
-		settings.getAggregate().addPlotsBeforeScatter(result, dataSeries);
+		settings.getAggregates().addPlots(result, dataSeries); 
 		
-		settings.getAggregate().addPlotsAfterScatter(result, dataSeries);
-
 		return result.toString();
 	}
 

pdb-plotting/src/main/java/org/lucares/recommind/logs/GnuplotSettings.java

@@ -2,7 +2,7 @@ package org.lucares.recommind.logs;
 
 import java.nio.file.Path;
 
-import org.lucares.pdb.plot.api.AggregateHandler;
+import org.lucares.pdb.plot.api.AggregateHandlerCollection;
 import org.lucares.pdb.plot.api.AxisScale;
 
 public class GnuplotSettings {
@@ -26,7 +26,7 @@ public class GnuplotSettings {
 	private final Path output;
 
 	private AxisScale yAxisScale;
-	private AggregateHandler aggregate;
+	private AggregateHandlerCollection aggregates;
 	private boolean keyOutside = false;
 
 	private XAxisSettings xAxisSettings = new XAxisSettings();
@@ -98,12 +98,12 @@ public class GnuplotSettings {
 		return yAxisScale;
 	}
 
-	public void setAggregate(final AggregateHandler aggregate) {
-		this.aggregate = aggregate;
+	public void setAggregates(final AggregateHandlerCollection aggregates) {
+		this.aggregates = aggregates;
 	}
 
-	public AggregateHandler getAggregate() {
-		return aggregate;
+	public AggregateHandlerCollection getAggregates() {
+		return aggregates;
 	}
 
 	public void setKeyOutside(final boolean keyOutside) {

pdb-plotting/src/main/java/org/lucares/recommind/logs/Plotter.java

@@ -22,7 +22,7 @@ import org.lucares.pdb.api.GroupResult;
 import org.lucares.pdb.api.Query;
 import org.lucares.pdb.api.Result;
 import org.lucares.pdb.api.Tags;
-import org.lucares.pdb.plot.api.CustomAggregator;
+import org.lucares.pdb.plot.api.AggregatorCollection;
 import org.lucares.pdb.plot.api.Limit;
 import org.lucares.pdb.plot.api.PlotSettings;
 import org.lucares.pdb.plot.api.TimeRangeUnitInternal;
@@ -115,7 +115,7 @@ public class Plotter {
         defineXAxis(gnuplotSettings, plotSettings.dateRange());
 
         gnuplotSettings.setYAxisScale(plotSettings.getYAxisScale());
-        gnuplotSettings.setAggregate(plotSettings.getAggregate());
+        gnuplotSettings.setAggregates(plotSettings.getAggregates());
         defineYRange(gnuplotSettings, plotSettings.getYRangeMin(), plotSettings.getYRangeMax(),
             plotSettings.getYRangeUnit());
         gnuplotSettings.setKeyOutside(plotSettings.isKeyOutside());
@@ -132,7 +132,7 @@ public class Plotter {
         defineXAxis(gnuplotSettings, plotSettings.dateRange());
 
         gnuplotSettings.setYAxisScale(plotSettings.getYAxisScale());
-        gnuplotSettings.setAggregate(plotSettings.getAggregate());
+        gnuplotSettings.setAggregates(plotSettings.getAggregates());
         defineYRange(gnuplotSettings, plotSettings.getYRangeMin(), plotSettings.getYRangeMax(),
             plotSettings.getYRangeUnit());
         gnuplotSettings.setKeyOutside(false);
@@ -205,7 +205,7 @@ public class Plotter {
     final long maxValue = plotSettings.getYRangeUnit() == TimeRangeUnitInternal.AUTOMATIC ? Long.MAX_VALUE
         : plotSettings.getYRangeUnit().toMilliSeconds(plotSettings.getYRangeMax());
 
-    final CustomAggregator aggregator = plotSettings.getAggregate().createCustomAggregator(tmpDir, plotSettings, fromEpochMilli,
+    final AggregatorCollection aggregator = plotSettings.getAggregates().createCustomAggregator(tmpDir, plotSettings, fromEpochMilli,
         toEpochMilli);
 
     int count = 0; // number of values in the x-axis range (used to compute stats)
@@ -228,8 +228,6 @@ public class Plotter {
 
         final long value = entry.get(i + 1);
 
-        
-
         // compute stats
         count++;
         statsMaxValue = Math.max(statsMaxValue, value);
@@ -293,7 +291,5 @@ public class Plotter {
     result.append(")");
 
     return result.toString();
-
   }
-
 }

pdb-ui/src/main/java/org/lucares/pdbui/PdbController.java

@@ -6,6 +6,7 @@ import java.io.OutputStream;
 import java.text.Collator;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.EnumSet;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Locale;
@@ -20,10 +21,10 @@ import org.lucares.pdb.api.DateTimeRange;
 import org.lucares.pdb.api.QueryWithCaretMarker;
 import org.lucares.pdb.api.QueryWithCaretMarker.ResultMode;
 import org.lucares.pdb.datastore.Proposal;
+import org.lucares.pdb.plot.api.Aggregate;
 import org.lucares.pdb.plot.api.AxisScale;
 import org.lucares.pdb.plot.api.Limit;
 import org.lucares.pdb.plot.api.PlotSettings;
-import org.lucares.pdbui.domain.Aggregate;
 import org.lucares.pdbui.domain.AutocompleteProposal;
 import org.lucares.pdbui.domain.AutocompleteProposalByValue;
 import org.lucares.pdbui.domain.AutocompleteResponse;
@@ -158,7 +159,7 @@ public class PdbController implements HardcodedValues, PropertyKeys {
 			@RequestParam(name = "limitBy.selected", defaultValue = "NO_LIMIT") final Limit limitBy,
 			@RequestParam(name = "dateRange") final String dateRange,
 			@RequestParam(name = "axisScale", defaultValue = "LINEAR") final AxisScale axisScale,
-			@RequestParam(name = "aggregate", defaultValue = "NONE") final Aggregate aggregate,
+			@RequestParam(name = "aggregates") final EnumSet<Aggregate>aggregate,
 			@RequestParam(name = "keyOutside", defaultValue = "false") final boolean keyOutside,
 			@RequestParam(name = "width", defaultValue = "1920") final int hidth,
 			@RequestParam(name = "height", defaultValue = "1080") final int height) {
@@ -181,7 +182,7 @@ public class PdbController implements HardcodedValues, PropertyKeys {
 			plotSettings.setLimitBy(limitBy);
 			plotSettings.setDateRange(dateRange);
 			plotSettings.setYAxisScale(axisScale);
-			plotSettings.setAggregate(PlotSettingsTransformer.toAggregateInternal(aggregate));
+			plotSettings.setAggregates(PlotSettingsTransformer.toAggregateInternal(aggregate));
 			plotSettings.setKeyOutside(keyOutside);
 			plotSettings.setGenerateThumbnail(false);
 

pdb-ui/src/main/java/org/lucares/pdbui/PlotSettingsTransformer.java

@@ -1,70 +1,78 @@
 package org.lucares.pdbui;
 
-import org.lucares.pdb.plot.api.AggregateHandler;
-import org.lucares.pdb.plot.api.NullAggregate;
-import org.lucares.pdb.plot.api.ParallelRequestsAggregate;
+import org.lucares.pdb.plot.api.Aggregate;
+import org.lucares.pdb.plot.api.AggregateHandlerCollection;
 import org.lucares.pdb.plot.api.CumulativeDistributionHandler;
+import org.lucares.pdb.plot.api.ParallelRequestsAggregate;
 import org.lucares.pdb.plot.api.PlotSettings;
 import org.lucares.pdb.plot.api.ScatterAggregateHandler;
 import org.lucares.pdb.plot.api.TimeRangeUnitInternal;
-import org.lucares.pdbui.domain.Aggregate;
 import org.lucares.pdbui.domain.PlotRequest;
 import org.lucares.pdbui.domain.TimeRangeUnit;
 
 class PlotSettingsTransformer {
-	static PlotSettings toSettings(final PlotRequest request) {
+  static PlotSettings toSettings(final PlotRequest request) {
 
-		final PlotSettings result = new PlotSettings();
+    final PlotSettings result = new PlotSettings();
 
-		result.setQuery(request.getQuery());
-		result.setGroupBy(request.getGroupBy());
-		result.setHeight(request.getHeight());
-		result.setWidth(request.getWidth());
-		result.setLimit(request.getLimit());
-		result.setLimitBy(request.getLimitBy());
-		result.setDateRange(request.getDateRange());
-		result.setYAxisScale(request.getAxisScale());
-		result.setAggregate(toAggregateInternal(request.getAggregate()));
-		result.setKeyOutside(request.isKeyOutside());
-		result.setThumbnailMaxWidth(request.getThumbnailMaxWidth());
-		result.setThumbnailMaxHeight(request.getThumbnailMaxHeight());
-		result.setGenerateThumbnail(request.isGenerateThumbnail());
-		result.setYRangeMin(request.getyRangeMin());
-		result.setYRangeMax(request.getyRangeMax());
-		result.setYRangeUnit(toTimeRangeUnitInternal(request.getyRangeUnit()));
+    result.setQuery(request.getQuery());
+    result.setGroupBy(request.getGroupBy());
+    result.setHeight(request.getHeight());
+    result.setWidth(request.getWidth());
+    result.setLimit(request.getLimit());
+    result.setLimitBy(request.getLimitBy());
+    result.setDateRange(request.getDateRange());
+    result.setYAxisScale(request.getAxisScale());
+    result.setAggregates(toAggregateInternal(request.getAggregates()));
+    result.setKeyOutside(request.isKeyOutside());
+    result.setThumbnailMaxWidth(request.getThumbnailMaxWidth());
+    result.setThumbnailMaxHeight(request.getThumbnailMaxHeight());
+    result.setGenerateThumbnail(request.isGenerateThumbnail());
+    result.setYRangeMin(request.getyRangeMin());
+    result.setYRangeMax(request.getyRangeMax());
+    result.setYRangeUnit(toTimeRangeUnitInternal(request.getyRangeUnit()));
 
-		return result;
-	}
+    return result;
+  }
 
-	private static TimeRangeUnitInternal toTimeRangeUnitInternal(final TimeRangeUnit yRangeUnit) {
-		switch (yRangeUnit) {
-		case AUTOMATIC:
-			return TimeRangeUnitInternal.AUTOMATIC;
-		case MILLISECONDS:
-			return TimeRangeUnitInternal.MILLISECONDS;
-		case SECONDS:
-			return TimeRangeUnitInternal.SECONDS;
-		case MINUTES:
-			return TimeRangeUnitInternal.MINUTES;
-		case HOURS:
-			return TimeRangeUnitInternal.HOURS;
-		case DAYS:
-			return TimeRangeUnitInternal.DAYS;
-		}
-		throw new IllegalStateException("unhandled enum value: " + yRangeUnit);
-	}
+  private static TimeRangeUnitInternal toTimeRangeUnitInternal(final TimeRangeUnit yRangeUnit) {
+    switch (yRangeUnit) {
+    case AUTOMATIC:
+      return TimeRangeUnitInternal.AUTOMATIC;
+    case MILLISECONDS:
+      return TimeRangeUnitInternal.MILLISECONDS;
+    case SECONDS:
+      return TimeRangeUnitInternal.SECONDS;
+    case MINUTES:
+      return TimeRangeUnitInternal.MINUTES;
+    case HOURS:
+      return TimeRangeUnitInternal.HOURS;
+    case DAYS:
+      return TimeRangeUnitInternal.DAYS;
+    }
+    throw new IllegalStateException("unhandled enum value: " + yRangeUnit);
+  }
 
-	static AggregateHandler toAggregateInternal(final Aggregate aggregate) {
-		switch (aggregate) {
-		case NONE:
-			return new NullAggregate();
-		case CUM_DISTRIBUTION:
-			return new CumulativeDistributionHandler();
-		case PARALLEL:
-			return new ParallelRequestsAggregate();
-		case SCATTER:
-		  return new ScatterAggregateHandler();
-		}
-		throw new IllegalStateException("unhandled enum: " + aggregate);
-	}
+  static AggregateHandlerCollection toAggregateInternal(final Iterable<Aggregate> aggregates) {
+    final AggregateHandlerCollection aggregateHandlerCollection = new AggregateHandlerCollection();
+
+    for (Aggregate aggregate : aggregates) {
+
+      switch (aggregate) {
+      case CUM_DISTRIBUTION:
+        aggregateHandlerCollection.add(new CumulativeDistributionHandler());
+        break;
+      case PARALLEL:
+        aggregateHandlerCollection.add(new ParallelRequestsAggregate());
+        break;
+      case SCATTER:
+        aggregateHandlerCollection.add(new ScatterAggregateHandler());
+        break;
+      default:
+        throw new IllegalStateException("unhandled enum: " + aggregate);
+      }
+    }
+
+    return aggregateHandlerCollection;
+  }
 }

pdb-ui/src/main/java/org/lucares/pdbui/domain/PlotRequest.java

@@ -1,7 +1,9 @@
 package org.lucares.pdbui.domain;
 
+import java.util.ArrayList;
 import java.util.List;
 
+import org.lucares.pdb.plot.api.Aggregate;
 import org.lucares.pdb.plot.api.AxisScale;
 import org.lucares.pdb.plot.api.Limit;
 
@@ -26,7 +28,7 @@ public class PlotRequest {
 
 	private String dateRange;
 
-	private Aggregate aggregate = Aggregate.NONE;
+	private List<Aggregate> aggregates = new ArrayList<>();
 
 	private int yRangeMin;
 	private int yRangeMax;
@@ -121,12 +123,12 @@ public class PlotRequest {
 		this.yAxis = yAxis;
 	}
 
-	public void setAggregate(final Aggregate aggregate) {
-		this.aggregate = aggregate;
+	public void setAggregate(final List<Aggregate> aggregates) {
+		this.aggregates = aggregates;
 	}
 
-	public Aggregate getAggregate() {
-		return aggregate;
+	public List<Aggregate> getAggregates() {
+		return aggregates;
 	}
 
 	public void setKeyOutside(final boolean keyOutside) {

pdb-ui/src/main/resources/resources/js/ui.js

@@ -780,7 +780,7 @@ Vue.component('search-bar', {
 			
 			<div class="group" id="group-show-aggregate">
 				<label for="show-aggregate">X2-Axis:</label>
-				<select id="show-aggregate" v-model="searchBar.aggregate">
+				<select id="show-aggregate" v-model="searchBar.aggregate" multiple>
 					<option value="NONE">-</option>
 					<option value="CUM_DISTRIBUTION" title="cumulative distribution, see https://serialmentor.com/dataviz/ecdf-qq.html">cum. distribution</option>
 					<option value="PARALLEL">parallel requests</option>