Skip to content

Commit fc0568e

Browse files
committed
no stream
1 parent 196d7d1 commit fc0568e

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/optimizer/rules/logical/TranslateTimeSeriesAggregate.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
import java.util.HashMap;
3333
import java.util.List;
3434
import java.util.Map;
35-
import java.util.stream.Stream;
3635

3736
/**
3837
* Rate aggregation is special because it must be computed per time series, regardless of the grouping keys.
@@ -235,6 +234,9 @@ private static List<? extends NamedExpression> mergeExpressions(
235234
List<? extends NamedExpression> aggregates,
236235
List<Expression> groupings
237236
) {
238-
return Stream.concat(aggregates.stream(), groupings.stream().map(Expressions::attribute)).toList();
237+
List<Attribute> merged = new ArrayList<>(aggregates.size() + groupings.size());
238+
aggregates.forEach(a -> merged.add(Expressions.attribute(a)));
239+
groupings.forEach(g -> merged.add(Expressions.attribute(g)));
240+
return merged;
239241
}
240242
}

0 commit comments

Comments
 (0)