(skywalking) 01/02: Update banyandb api

[hanahmily]

This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch bump-banyandb-api
in repository https://gitbox.apache.org/repos/asf/skywalking.git

commit d7c47357fd40f7d37d25e9e6a87d5687b25c0c57
Author: Gao Hongtao <hanahm...@gmail.com>
AuthorDate: Thu Apr 25 13:11:23 2024 +0800

    Update banyandb api
    
    Signed-off-by: Gao Hongtao <hanahm...@gmail.com>
---
 .../storage/plugin/banyandb/stream/AbstractBanyanDBDAO.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/stream/AbstractBanyanDBDAO.java
 
b/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/stream/AbstractBanyanDBDAO.java
index 2f66ee5069..250037bb38 100644
--- 
a/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/stream/AbstractBanyanDBDAO.java
+++ 
b/oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/stream/AbstractBanyanDBDAO.java
@@ -65,9 +65,9 @@ public abstract class AbstractBanyanDBDAO extends 
AbstractDAO<BanyanDBStorageCli
         }
         final StreamQuery query;
         if (timestampRange == null) {
-            query = new StreamQuery(schema.getMetadata().getGroup(), 
schema.getMetadata().name(), LARGEST_TIME_RANGE, tags);
+            query = new StreamQuery(List.of(schema.getMetadata().getGroup()), 
schema.getMetadata().name(), LARGEST_TIME_RANGE, tags);
         } else {
-            query = new StreamQuery(schema.getMetadata().getGroup(), 
schema.getMetadata().name(), timestampRange, tags);
+            query = new StreamQuery(List.of(schema.getMetadata().getGroup()), 
schema.getMetadata().name(), timestampRange, tags);
         }
 
         builder.apply(query);
@@ -92,7 +92,7 @@ public abstract class AbstractBanyanDBDAO extends 
AbstractDAO<BanyanDBStorageCli
 
     private TopNQueryResponse topNQuery(MetadataRegistry.Schema schema, 
TimestampRange timestampRange, int number,
                                         AbstractQuery.Sort sort, 
List<KeyValue> additionalConditions) throws IOException {
-        final TopNQuery q = new TopNQuery(schema.getMetadata().getGroup(), 
schema.getTopNSpec().getName(),
+        final TopNQuery q = new 
TopNQuery(List.of(schema.getMetadata().getGroup()), 
schema.getTopNSpec().getName(),
                 timestampRange,
                 number, sort);
         q.setAggregationType(MeasureQuery.Aggregation.Type.MEAN);
@@ -119,9 +119,9 @@ public abstract class AbstractBanyanDBDAO extends 
AbstractDAO<BanyanDBStorageCli
                                          TimestampRange timestampRange, 
QueryBuilder<MeasureQuery> builder) throws IOException {
         final MeasureQuery query;
         if (timestampRange == null) {
-            query = new MeasureQuery(schema.getMetadata().getGroup(), 
schema.getMetadata().name(), LARGEST_TIME_RANGE, tags, fields);
+            query = new MeasureQuery(List.of(schema.getMetadata().getGroup()), 
schema.getMetadata().name(), LARGEST_TIME_RANGE, tags, fields);
         } else {
-            query = new MeasureQuery(schema.getMetadata().getGroup(), 
schema.getMetadata().name(), timestampRange, tags, fields);
+            query = new MeasureQuery(List.of(schema.getMetadata().getGroup()), 
schema.getMetadata().name(), timestampRange, tags, fields);
         }
 
         builder.apply(query);