Данные - это набор кортежей в формате: (группа, номер)
data.map(a => (a._1, (a._2, 1)))
.reduceByKey((a,b) => (a._1 * b._1, a._2 + b._2))
.map(a => (a._1, pow(a._2._1, 1/a. 2._2))
Как новичок в Spark - что делает предоставленный код? Можете ли вы объяснить мне этот код?