BanyanDB: fix the BanyanDBMetricsDAO.multiGet not work properly in IndexMode. (#13457)

Author: wankai123

docs/en/changes/changes.md

@@ -88,6 +88,9 @@
 | **Total**                       | **158**   | -                           | -                                                                                                                                     |
 
 * BanyanDB: make `BanyanDBMetricsDAO` output `scan all blocks` info log only when the model is not `indexModel`.
+* BanyanDB: fix the `BanyanDBMetricsDAO.multiGet` not work properly in `IndexMode`.
+* BanyanDB: remove `@StoreIDAsTag`, and automatically create a virtual String tag `id` for the SeriesID in `IndexMode`.
+* Remove method `appendMutant` from StorageID.
 
 #### UI
 

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/cache/TopNCacheReadCommand.java

@@ -49,7 +49,7 @@ public class TopNCacheReadCommand extends TopN {
 
     @Override
     public StorageID id() {
-        return new StorageID().appendMutant(null, id);
+        return new StorageID().append(id);
     }
 
     @Override

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/cache/TopNCacheWriteCommand.java

@@ -49,7 +49,7 @@ public class TopNCacheWriteCommand extends TopN {
 
     @Override
     public StorageID id() {
-        return new StorageID().appendMutant(null, id);
+        return new StorageID().append(id);
     }
 
     @Override

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/database/TopNDatabaseStatement.java

@@ -49,7 +49,7 @@ public class TopNDatabaseStatement extends TopN {
 
     @Override
     public StorageID id() {
-        return new StorageID().appendMutant(null, id);
+        return new StorageID().append(id);
     }
 
     @Override

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/endpoint/EndpointTraffic.java

@@ -57,15 +57,13 @@ public class EndpointTraffic extends Metrics {
     @Setter
     @Getter
     @Column(name = SERVICE_ID)
-    @BanyanDB.SeriesID(index = 0)
     private String serviceId;
     @Setter
     @Getter
     @Column(name = NAME)
     @ElasticSearch.Column(legacyName = "name")
     @ElasticSearch.MatchQuery
     @BanyanDB.MatchQuery(analyzer = BanyanDB.MatchQuery.AnalyzerType.URL)
-    @BanyanDB.SeriesID(index = 1)
     private String name = Const.EMPTY_STRING;
     @Setter
     @Getter
@@ -77,11 +75,7 @@ protected StorageID id0() {
         // Downgrade the time bucket to day level only.
         // supportDownSampling == false for this entity.
         return new StorageID()
-            .appendMutant(
-                new String[] {
-                    SERVICE_ID,
-                    NAME
-                },
+            .append(
                 IDManager.EndpointID.buildId(
                     this.getServiceId(), this.getName())
             );

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/instance/InstanceTraffic.java

@@ -61,14 +61,12 @@ public class InstanceTraffic extends Metrics {
     @Setter
     @Getter
     @Column(name = SERVICE_ID)
-    @BanyanDB.SeriesID(index = 0)
     private String serviceId;
 
     @Setter
     @Getter
     @Column(name = NAME, storageOnly = true)
     @ElasticSearch.Column(legacyName = "name")
-    @BanyanDB.SeriesID(index = 1)
     private String name;
 
     @Setter
@@ -135,10 +133,7 @@ public RemoteData.Builder serialize() {
     @Override
     protected StorageID id0() {
         return new StorageID()
-            .appendMutant(new String[] {
-                SERVICE_ID,
-                NAME
-            }, IDManager.ServiceInstanceID.buildId(serviceId, name));
+            .append(IDManager.ServiceInstanceID.buildId(serviceId, name));
     }
 
     public static class Builder implements StorageBuilder<InstanceTraffic> {

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/networkalias/NetworkAddressAlias.java

@@ -55,17 +55,14 @@ public class NetworkAddressAlias extends Metrics {
     @Setter
     @Getter
     @Column(name = ADDRESS)
-    @BanyanDB.SeriesID(index = 0)
     private String address;
     @Setter
     @Getter
     @Column(name = REPRESENT_SERVICE_ID)
-    @BanyanDB.SeriesID(index = 1)
     private String representServiceId;
     @Setter
     @Getter
     @Column(name = REPRESENT_SERVICE_INSTANCE_ID)
-    @BanyanDB.SeriesID(index = 2)
     private String representServiceInstanceId;
     @Setter
     @Getter
@@ -89,8 +86,7 @@ public boolean combine(final Metrics metrics) {
 
     @Override
     protected StorageID id0() {
-        return new StorageID().appendMutant(
-            new String[] {ADDRESS}, IDManager.NetworkAddressAliasDefine.buildId(address));
+        return new StorageID().append(IDManager.NetworkAddressAliasDefine.buildId(address));
     }
 
     @Override

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/process/ProcessTraffic.java

@@ -50,7 +50,6 @@
     "instanceId",
     "name",
 })
-@BanyanDB.StoreIDAsTag
 @BanyanDB.IndexMode
 public class ProcessTraffic extends Metrics {
     public static final String INDEX_NAME = "process_traffic";
@@ -74,7 +73,6 @@ public class ProcessTraffic extends Metrics {
     @Setter
     @Getter
     @Column(name = INSTANCE_ID, length = 600)
-    @BanyanDB.SeriesID(index = 0)
     private String instanceId;
 
     @Getter
@@ -84,7 +82,6 @@ public class ProcessTraffic extends Metrics {
     @Setter
     @Getter
     @Column(name = NAME, length = 500)
-    @BanyanDB.SeriesID(index = 1)
     private String name;
 
     @Setter
@@ -196,10 +193,7 @@ protected StorageID id0() {
         if (processId == null) {
             processId = IDManager.ProcessID.buildId(instanceId, name);
         }
-        return new StorageID().appendMutant(new String[] {
-            INSTANCE_ID,
-            NAME
-        }, processId);
+        return new StorageID().append(processId);
     }
 
     public static class Builder implements StorageBuilder<ProcessTraffic> {

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/process/ServiceLabelRecord.java

@@ -55,10 +55,8 @@ public class ServiceLabelRecord extends Metrics {
     public static final String SERVICE_ID = "service_id";
     public static final String LABEL = "label";
 
-    @BanyanDB.SeriesID(index = 0)
     @Column(name = SERVICE_ID)
     private String serviceId;
-    @BanyanDB.SeriesID(index = 1)
     @Column(name = LABEL, length = 50)
     private String label;
 
@@ -83,9 +81,7 @@ public Metrics toDay() {
 
     @Override
     protected StorageID id0() {
-        return new StorageID()
-            .append(SERVICE_ID, serviceId)
-            .append(LABEL, label);
+        return new StorageID().append(serviceId).append(label);
     }
 
     @Override

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/searchtag/TagAutocompleteData.java

@@ -57,18 +57,15 @@ public class TagAutocompleteData extends Metrics {
     @Getter
     @Column(name = TAG_KEY)
     @ElasticSearch.EnableDocValues
-    @BanyanDB.SeriesID(index = 1)
     private String tagKey;
     @Setter
     @Getter
     @Column(name = TAG_VALUE, length = Tag.TAG_LENGTH)
-    @BanyanDB.SeriesID(index = 2)
     private String tagValue;
 
     @Setter
     @Getter
     @Column(name = TAG_TYPE)
-    @BanyanDB.SeriesID(index = 0)
     private String tagType;
 
     @Override
@@ -94,10 +91,10 @@ public Metrics toDay() {
     @Override
     protected StorageID id0() {
         return new StorageID()
-            .appendMutant(new String[] {TIME_BUCKET}, toTimeBucketInDay())
-            .append(TAG_TYPE, tagType)
-            .append(TAG_KEY, tagKey)
-            .append(TAG_VALUE, tagValue);
+            .append(toTimeBucketInDay())
+            .append(tagType)
+            .append(tagKey)
+            .append(tagValue);
     }
 
     @Override