Skip to content

Commit eca7a7f

Browse files
committed
Reduce rows returned from database when querying Labels
1 parent 1727fea commit eca7a7f

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

pkg/parcacol/querier.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ func (q *Querier) Labels(
118118

119119
err := q.engine.ScanTable(q.tableName).
120120
Filter(logicalplan.And(filterExpr...)).
121-
Project(logicalplan.DynCol(profile.ColumnLabels)).
121+
Distinct(logicalplan.DynCol(profile.ColumnLabels)).
122122
Execute(ctx, func(ctx context.Context, r arrow.Record) error {
123123
r.Retain()
124124
for i := 0; i < int(r.NumCols()); i++ {

0 commit comments

Comments
 (0)