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 = {