more explicit

echeipesh · echeipesh · commit eb8ccb92473c · 2022-12-14T13:11:36.000-05:00
diff --git a/core/src/main/scala/org/locationtech/rasterframes/expressions/aggregates/ApproxCellQuantilesAggregate.scala b/core/src/main/scala/org/locationtech/rasterframes/expressions/aggregates/ApproxCellQuantilesAggregate.scala
@@ -71,7 +71,7 @@ case class ApproxCellQuantilesAggregate(probabilities: Seq[Double], relativeErro
 
   def evaluate(buffer: Row): Seq[Double] = {
     val summaries = buffer.getStruct(0).as[QuantileSummaries]
-    probabilities.flatMap(summaries.query)
+    probabilities.flatMap(quantile => summaries.query(quantile))
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,7 @@ case class ApproxCellQuantilesAggregate(probabilities: Seq[Double], relativeErro`
`71`	`71`
`72`	`72`	`def evaluate(buffer: Row): Seq[Double] = {`
`73`	`73`	`val summaries = buffer.getStruct(0).as[QuantileSummaries]`
`74`		`- probabilities.flatMap(summaries.query)`
	`74`	`+ probabilities.flatMap(quantile => summaries.query(quantile))`
`75`	`75`	`}`
`76`	`76`	`}`
`77`	`77`