IP
Size: a a a
2019 November 19
RI
ты аггрегировал как-то? Там можно указать alias для колонки.
IP
ты аггрегировал как-то? Там можно указать alias для колонки.
типа такого alias(sum(COUNT))?
RI
типа такого alias(sum(COUNT))?
возможно, но с таким написанием не сталкивался. Скорее
sum().alias("")IP
возможно, но с таким написанием не сталкивался. Скорее
sum().alias("")
IP
чет не выходит
AS
sum("COUNT").alias('COUNT')
IP
sum("COUNT").alias('COUNT')
AS
так в sum надо указать колонку по которой вы суммируете
AS
SALES например. я просто не понимаю что идет на выходе из calculateData
AS
а глянул посмотрел. ну у вас есть колонка sum('COUNT') уже. тоесть суммирования делать не надо
IP
а глянул посмотрел. ну у вас есть колонка sum('COUNT') уже. тоесть суммирования делать не надо
как мне к ней обратиться, скажите пожалуйста?
AS
dfResult.select(f.col("sum(\'COUNT\')"))
AS
если скала то f.col это примерно так $"sum(\'COUNT\')"
AS
я скалу не пользовал могу ошибатся
AS
или использовать alias внутри функции calculateData
AS
я думаю вам стоит почитать книжку по спарку
AS
аггрегирующая функция например sum от col1 даст по умолчанию название колонки 'sum('col1')'
AS
для того чтобы это поменять надо использовать alias
AS
хотя из лога видно что у вас колонки идут без кавычек тоесть возможно так 'sum(COUNT)'