Skip to content

Commit

Permalink
scalastyle
Browse files Browse the repository at this point in the history
  • Loading branch information
alextheimer committed Feb 1, 2024
1 parent 9cefbae commit 951cbd7
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 4 deletions.
Original file line number Diff line number Diff line change
@@ -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}
Expand Down
Original file line number Diff line number Diff line change
@@ -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)
Expand Down Expand Up @@ -866,3 +869,5 @@ class MultiPartitionPlanner(val partitionLocationProvider: PartitionLocationProv
urlParams, finalQueryContext, inProcessPlanDispatcher, dataset.ref, remoteExecHttpClient, queryConfig)
}
}

//scalastyle:on file.size.limit
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 951cbd7

Please sign in to comment.