From aff7ac4a450f7813df75d04a8c55671e52a216fb Mon Sep 17 00:00:00 2001 From: Amol Nayak Date: Wed, 13 Dec 2023 14:18:10 -0800 Subject: [PATCH] WIP --- .../queryplanner/SingleClusterPlanner.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala b/coordinator/src/main/scala/filodb.coordinator/queryplanner/SingleClusterPlanner.scala index b200c17a1d..c6c4368f86 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 def materializePeriodicSeriesWithWindowing(qContext: QueryContext, + 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 def removeBucket(lp: Either[PeriodicSeries, PeriodicSeriesWithWindowing]) = { + 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 def materializePeriodicSeries(qContext: QueryContext, + private[queryplanner] def materializePeriodicSeries(qContext: QueryContext, lp: PeriodicSeries, forceInProcess: Boolean): PlanResult = {