bot/WeatherTool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Implicit for rounding double values to first decimal

Browse Source
This commit is contained in:
Guntis Smaukstelis
2023-05-22 22:24:12 +03:00
parent 760ef4e719
commit 18f6424397
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/scala/parse/Aggregate.scala
+8 -4
View File
@@ -101,6 +101,10 @@ object Aggregate {
case _ => List.empty case _ => List.empty
} }
implicit class RoundDecimal(val d: Double) extends AnyVal {
def roundDecimal: Double = BigDecimal(d).setScale(1, BigDecimal.RoundingMode.HALF_UP).toDouble
}
def aggregateDoubleValues( def aggregateDoubleValues(
AggKey: AggregateKey, AggKey: AggregateKey,
values: List[Option[Double]], values: List[Option[Double]],
@@ -108,10 +112,10 @@ object Aggregate {
): Option[AggregateValue] = { ): Option[AggregateValue] = {
val flatValues = values.flatten val flatValues = values.flatten
AggKey match { AggKey match {
case AggregateKey.Min => flatValues.minimumOption.map(DoubleValue) case AggregateKey.Min => flatValues.minimumOption.map(value => DoubleValue(value.roundDecimal))
case AggregateKey.Max => flatValues.maximumOption.map(DoubleValue) case AggregateKey.Max => flatValues.maximumOption.map(value => DoubleValue(value.roundDecimal))
case AggregateKey.Avg => flatValues.reduceOption(_ + _).map(sum => DoubleValue(sum / flatValues.length)) case AggregateKey.Avg => flatValues.reduceOption(_ + _).map(sum => DoubleValue((sum / flatValues.length).roundDecimal))
case AggregateKey.Sum => flatValues.sum.some.map(DoubleValue) case AggregateKey.Sum => flatValues.sum.some.map(value => DoubleValue(value.roundDecimal))
case AggregateKey.List => TimeDoubleList(timestamps.zip(values).sorted).some case AggregateKey.List => TimeDoubleList(timestamps.zip(values).sorted).some
case AggregateKey.Distinct => None case AggregateKey.Distinct => None
} }