Skip to content

Commit

Permalink
Fixed linting
Browse files Browse the repository at this point in the history
  • Loading branch information
mference committed Jan 3, 2025
1 parent c597194 commit 8f0bdb0
Showing 1 changed file with 5 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,10 @@ package filodb.coordinator.queryplanner


import java.util.concurrent.ThreadLocalRandom

import akka.serialization.SerializationExtension
import com.typesafe.scalalogging.StrictLogging

import filodb.coordinator.{ActorPlanDispatcher, ActorSystemHolder, GrpcPlanDispatcher, RemoteActorPlanDispatcher}
import filodb.core.metadata.{Dataset, DatasetOptions, Schemas}
import filodb.core.query._
Expand Down Expand Up @@ -231,13 +233,9 @@ trait DefaultPlanner {
lp: ApplyMiscellaneousFunction,
forceInProcess: Boolean = false): PlanResult = {
val vectors = walkLogicalPlanTree(lp.vectors, qContext, forceInProcess)
if (lp.function == MiscellaneousFunctionId.OptimizeWithAgg)
{
// The `Optimize` function is a no-operation (no-op), meaning it does not perform any transformation or
// computation. However, it is necessary to pass it through to the execution plan without any modifications when
// dealing with an "Optimize with Aggregation" query. This ensures that the optimization logic is preserved
// and applied correctly during the aggregation phase, without interfering with the underlying data
// or query execution flow.
if (lp.function == MiscellaneousFunctionId.OptimizeWithAgg) {
// Optimize` is a no-op that preserves optimization logic in
// aggregation queries, ensuring correct execution without modifying underlying data.
vectors
} else {
if (lp.function == MiscellaneousFunctionId.HistToPromVectors)
Expand Down

0 comments on commit 8f0bdb0

Please sign in to comment.