feat(storage/flux): add group min/max pushdown

influxdata · Apr 6, 2021 · a5383df · a5383df
1 parent 65c3851
commit a5383df
Show file tree

Hide file tree

Showing 4 changed files with 122 additions and 84 deletions.
diff --git a/query/stdlib/influxdata/influxdb/min_max_influxdb_test.flux b/query/stdlib/influxdata/influxdb/min_max_influxdb_test.flux
@@ -13,6 +13,24 @@ testcase push_down_min_bare extends "flux/planner/group_min_test" {
     group_min_test.group_min_bare()
 }
 
+testcase push_down_min_bare_host extends "flux/planner/group_min_test" {
+    expect.planner(rules: [
+        "PushDownGroupAggregateRule": 1,
+        "PushDownRangeRule": 1,
+        "PushDownFilterRule": 1,
+    ])
+    group_min_test.group_min_bare_host()
+}
+
+testcase push_down_min_bare_field extends "flux/planner/group_min_test" {
+    expect.planner(rules: [
+        "PushDownGroupAggregateRule": 1,
+        "PushDownRangeRule": 1,
+        "PushDownFilterRule": 1,
+    ])
+    group_min_test.group_min_bare_field()
+}
+
 testcase push_down_max_bare extends "flux/planner/group_max_test" {
     expect.planner(rules: [
         "PushDownGroupAggregateRule": 1,
@@ -21,3 +39,21 @@ testcase push_down_max_bare extends "flux/planner/group_max_test" {
     ])
     group_max_test.group_max_bare()
 }
+
+testcase push_down_max_bare_host extends "flux/planner/group_max_test" {
+    expect.planner(rules: [
+        "PushDownGroupAggregateRule": 1,
+        "PushDownRangeRule": 1,
+        "PushDownFilterRule": 1,
+    ])
+    group_max_test.group_max_bare_host()
+}
+
+testcase push_down_max_bare_field extends "flux/planner/group_max_test" {
+    expect.planner(rules: [
+        "PushDownGroupAggregateRule": 1,
+        "PushDownRangeRule": 1,
+        "PushDownFilterRule": 1,
+    ])
+    group_max_test.group_max_bare_field()
+}