Optimize coalesce (#508)

If coalesce has a single downstream operator, we can skip it and directly return the downstream. Signed-off-by: Filip Petkovski <[email protected]>
thanos-io · Jan 13, 2025 · 1630e99 · 1630e99
1 parent 14f9955
commit 1630e99
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/execution/exchange/coalesce.go b/execution/exchange/coalesce.go
@@ -53,6 +53,9 @@ type coalesce struct {
 }
 
 func NewCoalesce(pool *model.VectorPool, opts *query.Options, batchSize int64, operators ...model.VectorOperator) model.VectorOperator {
+	if len(operators) == 1 {
+		return operators[0]
+	}
 	oper := &coalesce{
 		pool:          pool,
 		sampleOffsets: make([]uint64, len(operators)),