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();
     }
 }

Reply via email to