perf: improve local table

deepflowio · Nov 28, 2024 · 627107c · 627107c
1 parent 68e1ed5
commit 627107c
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/server/libs/ckdb/table.go b/server/libs/ckdb/table.go
@@ -497,20 +497,18 @@ func (t *Table) MakeAggrLocalTableCreateSQL(orgID uint16, aggrInterval Aggregati
 				groupKeys = append(groupKeys, c.Name)
 			}
 		} else {
-			columns = append(columns, fmt.Sprintf("%sMerge(%s__agg) AS %s", getAggr(c), c.Name, c.Name))
+			columns = append(columns, fmt.Sprintf("finalizeAggregation(%s__agg) AS %s", c.Name, c.Name))
 		}
 	}
 
 	return fmt.Sprintf(`
 CREATE VIEW IF NOT EXISTS %s
 AS SELECT
 %s
-FROM %s
-GROUP BY %s`,
+FROM %s`,
 		tableLocal,
 		strings.Join(columns, ",\n"),
-		tableAgg,
-		strings.Join(groupKeys, ","))
+		tableAgg)
 }
 
 func (t *Table) MakeAggrGlobalTableCreateSQL(orgID uint16, aggrInterval AggregationInterval) string {