update DS QueryStats key

filodb · Sep 1, 2023 · 744e438 · 744e438
1 parent fac0efb
commit 744e438
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/src/main/scala/filodb.core/downsample/DownsampledTimeSeriesShard.scala b/core/src/main/scala/filodb.core/downsample/DownsampledTimeSeriesShard.scala
@@ -21,7 +21,8 @@ import filodb.core.binaryrecord2.RecordSchema
 import filodb.core.memstore._
 import filodb.core.memstore.ratelimit.{CardinalityManager, CardinalityRecord, QuotaSource}
 import filodb.core.metadata.Schemas
-import filodb.core.query.{ColumnFilter, Filter, QueryContext, QueryLimitException, QuerySession, QueryWarnings}
+import filodb.core.query.{ColumnFilter, Filter, QueryContext, QueryLimitException,
+                          QuerySession, QueryUtils, QueryWarnings}
 import filodb.core.store._
 import filodb.memory.format.{UnsafeUtils, ZeroCopyUTF8String}
 import filodb.memory.format.ZeroCopyUTF8String._
@@ -353,6 +354,8 @@ class DownsampledTimeSeriesShard(rawDatasetRef: DatasetRef,
           val metricGroupBy = deploymentPartitionName +: clusterType +: metricShardKeys.map { col =>
             filters.collectFirst {
               case ColumnFilter(c, Filter.Equals(filtVal: String)) if c == col => filtVal
+              case ColumnFilter(c, Filter.EqualsRegex(filtVal: String))
+                if c == col && !QueryUtils.containsUnescapedNonPipeRegexChars(filtVal) => "multiple"
             }.getOrElse("unknown")
           }.toList
           querySession.queryStats.getTimeSeriesScannedCounter(metricGroupBy).addAndGet(recs.length)