feat: DH-18856: Add Median to jsapi Aggregation Options (#6700)

https://deephaven.atlassian.net/browse/DH-18856

Tested using the following branch from `web-client-ui`:
https://github.com/dgodinez-dh/web-client-ui/tree/dag_MedianAgg
Tested median on numeric, string, and date columns.

Author: dgodinez-dh

web/client-api/src/main/java/io/deephaven/web/client/api/JsTotalsTableConfig.java

@@ -20,6 +20,7 @@
 import io.deephaven.javascript.proto.dhinternal.io.deephaven_core.proto.table_pb.aggspec.AggSpecFirst;
 import io.deephaven.javascript.proto.dhinternal.io.deephaven_core.proto.table_pb.aggspec.AggSpecLast;
 import io.deephaven.javascript.proto.dhinternal.io.deephaven_core.proto.table_pb.aggspec.AggSpecMax;
+import io.deephaven.javascript.proto.dhinternal.io.deephaven_core.proto.table_pb.aggspec.AggSpecMedian;
 import io.deephaven.javascript.proto.dhinternal.io.deephaven_core.proto.table_pb.aggspec.AggSpecMin;
 import io.deephaven.javascript.proto.dhinternal.io.deephaven_core.proto.table_pb.aggspec.AggSpecNonUniqueSentinel;
 import io.deephaven.javascript.proto.dhinternal.io.deephaven_core.proto.table_pb.aggspec.AggSpecStd;
@@ -70,14 +71,15 @@ public class JsTotalsTableConfig {
             LAST = "Last",
             // ARRAY = "Array",
             SKIP = "Skip";
-    private static final List<String> knownAggTypes = Arrays.asList(
+    protected static final List<String> knownAggTypes = Arrays.asList(
             JsAggregationOperation.COUNT,
             JsAggregationOperation.MIN,
             JsAggregationOperation.MAX,
             JsAggregationOperation.SUM,
             JsAggregationOperation.ABS_SUM,
             JsAggregationOperation.VAR,
             JsAggregationOperation.AVG,
+            JsAggregationOperation.MEDIAN,
             JsAggregationOperation.STD,
             JsAggregationOperation.FIRST,
             JsAggregationOperation.LAST,
@@ -357,6 +359,15 @@ public AggregateRequest buildRequest(JsArray<Column> allColumns) {
                     agg.setColumns(columns);
                     break;
                 }
+                case JsAggregationOperation.MEDIAN: {
+                    AggSpec spec = new AggSpec();
+                    spec.setMedian(new AggSpecMedian());
+                    columns = new AggregationColumns();
+                    columns.setSpec(spec);
+                    columns.setMatchPairsList(aggColumns);
+                    agg.setColumns(columns);
+                    break;
+                }
                 case JsAggregationOperation.STD: {
                     AggSpec spec = new AggSpec();
                     spec.setStd(new AggSpecStd());

web/client-api/src/main/java/io/deephaven/web/client/api/tree/enums/JsAggregationOperation.java

@@ -58,6 +58,11 @@ public class JsAggregationOperation {
              * "Avg".
              */
             AVG = "Avg",
+            /**
+             * The median of all values in the specified column. Can only apply to numeric types. String value is
+             * "Median".
+             */
+            MEDIAN = "Median",
             /**
              * The sample standard deviation of all values in the specified column. Can only apply to numeric types.
              * String value is "Std". Sample standard deviation is computed using Bessel's correction
@@ -111,6 +116,7 @@ public static boolean canAggregateType(String aggregationType, String columnType
             case STD: {
                 return isNumeric(columnType);
             }
+            case MEDIAN:
             case MIN:
             case MAX: {
                 // Can only apply to Comparables - JS can't work this out, so we'll stick to known types

web/client-api/src/test/java/io/deephaven/web/client/api/TotalsTableTestGwt.java

@@ -11,9 +11,16 @@
 import io.deephaven.web.client.api.filter.FilterCondition;
 import io.deephaven.web.client.api.filter.FilterValue;
 import io.deephaven.web.client.api.subscription.ViewportData;
+import io.deephaven.web.client.api.tree.enums.JsAggregationOperation;
 import jsinterop.base.Js;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
 import java.util.function.Consumer;
+import java.util.function.Supplier;
+
+import static java.util.Map.entry;
 
 public class TotalsTableTestGwt extends AbstractAsyncGwtTestCase {
     private final TableSourceBuilder tables = new TableSourceBuilder()
@@ -24,6 +31,20 @@ public class TotalsTableTestGwt extends AbstractAsyncGwtTestCase {
                             +
                             ".with_attributes({'TotalsTable':'false,false,Count;J=Min:Avg,K=Skip,;'})");
 
+    // This will need to be updated to reflect values from JsTotalsTableConfig.knownAggTypes
+    // These are the values calculated for each Agg for column I of the "hasTotals" table
+    private final Map<String, Double> AggValueMap = Map.ofEntries(
+            entry(JsAggregationOperation.MIN, 0.0),
+            entry(JsAggregationOperation.MAX, 4.0),
+            entry(JsAggregationOperation.SUM, 10.0),
+            entry(JsAggregationOperation.ABS_SUM, 10.0),
+            entry(JsAggregationOperation.VAR, 2.5),
+            entry(JsAggregationOperation.AVG, 2.0),
+            entry(JsAggregationOperation.MEDIAN, 2.0),
+            entry(JsAggregationOperation.STD, 1.5811388300841898),
+            entry(JsAggregationOperation.FIRST, 0.0),
+            entry(JsAggregationOperation.LAST, 4.0));
+
     public void testQueryDefinedConfigs() {
         connect(tables)
                 .then(session -> {
@@ -371,6 +392,36 @@ public void testGroupedTotals() {
                 .then(this::finish).catch_(this::report);
     }
 
+    public void testCreateTotalsTableAggTypes() {
+        connect(tables)
+                .then(table("hasTotals"))
+                .then(table -> {
+                    List<Supplier<Promise<JsTotalsTable>>> tests = new ArrayList<>();
+                    List<String> aggs = JsTotalsTableConfig.knownAggTypes;
+                    for (int i = 0; i < aggs.size(); i++) {
+                        String operation = aggs.get(i);
+                        JsTotalsTableConfig config = new JsTotalsTableConfig();
+                        config.operationMap.set("I",
+                                Js.uncheckedCast(new JsString[] {toJsString(operation)}));
+                        tests.add(() -> table.getTotalsTable(config).then(totals -> {
+                            totals.setViewport(0, 100, null, null, null);
+
+                            return waitForEvent(totals, JsTable.EVENT_UPDATED, update -> {
+                                ViewportData viewportData = (ViewportData) update.getDetail();
+                                assertEquals(1, viewportData.getRows().length);
+                                if (AggValueMap.containsKey(operation)) {
+                                    assertEquals(AggValueMap.get(operation),
+                                            viewportData.getRows().getAt(0).get(totals.findColumn("I")).asDouble());
+                                }
+                            }, 1500);
+                        }));
+                    }
+
+                    return tests.stream().reduce((p1, p2) -> () -> p1.get().then(result -> p2.get())).get().get();
+                })
+                .then(this::finish).catch_(this::report);
+    }
+
     private static class TotalsResults {
         int k;
         long i;