morphir-elm
morphir-elm copied to clipboard
Morphir SDK Aggregation API Spark Transpilation - weighted averages
i.e. the function Morphir.SDK.Aggregate.weightedAverageOf
.
Unlike the other aggregation functions, this one takes two arguments, one gets the value (like the others do), but an extra function to get the weighting.
The first part of doing this task is identifying how to do a weighted average in Spark.