This is an automated email from the ASF dual-hosted git repository. hanahmily pushed a commit to branch topn in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb-java-client.git
commit 996962e10e372c28b0e1061be63644603bcdb893 Author: Gao Hongtao <hanahm...@gmail.com> AuthorDate: Wed May 21 09:46:57 2025 +0800 Update TopNQuery to support multiple stages Signed-off-by: Gao Hongtao <hanahm...@gmail.com> --- .../java/org/apache/skywalking/banyandb/v1/client/TopNQuery.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/org/apache/skywalking/banyandb/v1/client/TopNQuery.java b/src/main/java/org/apache/skywalking/banyandb/v1/client/TopNQuery.java index 8f40d91..84f819e 100644 --- a/src/main/java/org/apache/skywalking/banyandb/v1/client/TopNQuery.java +++ b/src/main/java/org/apache/skywalking/banyandb/v1/client/TopNQuery.java @@ -34,6 +34,7 @@ public class TopNQuery { private final int number; private final AbstractQuery.Sort sort; private MeasureQuery.Aggregation.Type aggregationType = MeasureQuery.Aggregation.Type.UNSPECIFIED; + private List<String> stages; /** * Query conditions. */ @@ -69,6 +70,11 @@ public class TopNQuery { bld.addConditions(expr.build().getCondition()); } } + if (stages != null && !stages.isEmpty()) { + for (String stage : stages) { + bld.addStages(stage); + } + } return bld.build(); } }