From 951cbd7f7c497e318f6a72a27ca28d026c00f66c Mon Sep 17 00:00:00 2001 From: Alex Theimer Date: Wed, 31 Jan 2024 21:32:32 -0800 Subject: [PATCH] scalastyle --- .../queryplanner/LogicalPlanUtils.scala | 4 +++- .../queryplanner/MultiPartitionPlanner.scala | 11 ++++++++--- .../queryplanner/SingleClusterPlanner.scala | 2 ++ 3 files changed, 13 insertions(+), 4 deletions(-) diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/LogicalPlanUtils.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/LogicalPlanUtils.scala index c969265810..e68a826284 100644 --- a/coordinator/src/main/scala/filodb.coordinator/queryplanner/LogicalPlanUtils.scala +++ b/coordinator/src/main/scala/filodb.coordinator/queryplanner/LogicalPlanUtils.scala @@ -1,8 +1,10 @@ package filodb.coordinator.queryplanner -import scala.collection.{Seq, mutable} +import scala.collection.{mutable, Seq} import scala.collection.mutable.ArrayBuffer + import com.typesafe.scalalogging.StrictLogging + import filodb.core.TargetSchemaProvider import filodb.core.query.{ColumnFilter, QueryContext, QueryUtils, RangeParams} import filodb.core.query.Filter.{Equals, EqualsRegex} diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala index 61785a1595..b083960d06 100644 --- a/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala +++ b/coordinator/src/main/scala/filodb.coordinator/queryplanner/MultiPartitionPlanner.scala @@ -1,23 +1,26 @@ package filodb.coordinator.queryplanner import java.util.concurrent.ConcurrentHashMap + import scala.collection.concurrent.{Map => ConcurrentMap} +import scala.collection.mutable import scala.collection.mutable.ListBuffer import scala.jdk.CollectionConverters._ + import com.typesafe.scalalogging.StrictLogging import io.grpc.ManagedChannel + import filodb.coordinator.queryplanner.LogicalPlanUtils._ import filodb.coordinator.queryplanner.PlannerUtil.rewritePlanWithRemoteRawExport import filodb.core.metadata.{Dataset, DatasetOptions, Schemas} -import filodb.core.query.Filter.{Equals, EqualsRegex} import filodb.core.query.{ColumnFilter, PromQlQueryParams, QueryConfig, QueryContext, QueryUtils, RangeParams, RvRange} +import filodb.core.query.Filter.{Equals, EqualsRegex} import filodb.grpc.GrpcCommonUtils import filodb.query._ import filodb.query.LogicalPlan._ import filodb.query.exec._ - -import scala.collection.mutable +//scalastyle:off file.size.limit case class PartitionAssignment(partitionName: String, httpEndPoint: String, timeRange: TimeRange, grpcEndPoint: Option[String] = None) @@ -866,3 +869,5 @@ class MultiPartitionPlanner(val partitionLocationProvider: PartitionLocationProv urlParams, finalQueryContext, inProcessPlanDispatcher, dataset.ref, remoteExecHttpClient, queryConfig) } } + +//scalastyle:on file.size.limit diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala index d7b180dbad..915bb97f68 100644 --- a/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala +++ b/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala @@ -2,9 +2,11 @@ package filodb.coordinator.queryplanner import scala.collection.mutable.ArrayBuffer import scala.concurrent.duration._ + import akka.actor.ActorRef import com.typesafe.scalalogging.StrictLogging import kamon.Kamon + import filodb.coordinator.{ActorPlanDispatcher, ShardMapper} import filodb.coordinator.client.QueryCommands.StaticSpreadProvider import filodb.coordinator.queryplanner.SingleClusterPlanner.findTargetSchema