Блог

У меня есть класс case :

case class User(date: String, type: String, car: String, house String, income: BigDecimal)

Я запускаю запрос для возврата агрегированных данных, таких как:

 def user(data : Dataset[User]): Dataset[User] = {
    user.groupBy("date", "car", "house")
        .sum("income")
        .select("date", "car", "house", "sum(income)")
        .withColumNameRenamed("sum(income)", "income")
}
  

Я хочу преобразовать результат обратно в набор данных класса case [User] и вернуть все агрегированные данные