Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
amolnayak311 committed Dec 13, 2023
1 parent 04f8c1e commit aff7ac4
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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 = {

Expand Down

0 comments on commit aff7ac4

Please sign in to comment.