From f5595f6c4f41308cc9c0f12e4a25898933bd8474 Mon Sep 17 00:00:00 2001 From: Amol Nayak Date: Wed, 13 Dec 2023 14:25:51 -0800 Subject: [PATCH] WIP --- .../filodb.coordinator/queryplanner/DefaultPlanner.scala | 2 +- .../queryplanner/SingleClusterPlanner.scala | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/DefaultPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/DefaultPlanner.scala index d873f8335c..fd2519d27f 100644 --- a/coordinator/src/main/scala/filodb.coordinator/queryplanner/DefaultPlanner.scala +++ b/coordinator/src/main/scala/filodb.coordinator/queryplanner/DefaultPlanner.scala @@ -179,7 +179,7 @@ trait DefaultPlanner { } } - def materializePeriodicSeries(qContext: QueryContext, + private[queryplanner] def materializePeriodicSeries(qContext: QueryContext, lp: PeriodicSeries, forceInProcess: Boolean): PlanResult = { diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala index c6c4368f86..6ea2fa1ec6 100644 --- a/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala +++ b/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala @@ -558,7 +558,7 @@ class SingleClusterPlanner(val dataset: Dataset, } } - private[queryplanner] def materializePeriodicSeriesWithWindowing(qContext: QueryContext, + override private[queryplanner] def materializePeriodicSeriesWithWindowing(qContext: QueryContext, lp: PeriodicSeriesWithWindowing, forceInProcess: Boolean): PlanResult = { val logicalPlanWithoutBucket = if (queryConfig.translatePromToFilodbHistogram) { @@ -605,7 +605,7 @@ class SingleClusterPlanner(val dataset: Dataset, result } - private[queryplanner] def removeBucket(lp: Either[PeriodicSeries, PeriodicSeriesWithWindowing]) = { + override private[queryplanner] def removeBucket(lp: Either[PeriodicSeries, PeriodicSeriesWithWindowing]) = { val rawSeries = lp match { case Right(value) => value.series case Left(value) => value.rawSeries @@ -633,7 +633,7 @@ class SingleClusterPlanner(val dataset: Dataset, case _ => (None, None, lp) } } - private[queryplanner] def materializePeriodicSeries(qContext: QueryContext, + override private[queryplanner] def materializePeriodicSeries(qContext: QueryContext, lp: PeriodicSeries, forceInProcess: Boolean): PlanResult = {