IP
для того чтобы это поменять надо использовать alias
Size: a a a
2019 November 19
AS
если надо переименовать колонку то надо использовать withcolumnrenamed
IP
если надо переименовать колонку то надо использовать withcolumnrenamed
да все пошло, только почемуто аррэй пустой получается
AS
Попробуйте без кавычек col('sum(COUNT)')
AS
Там в логе видны названия колонок после агрегации
IP
Там в логе видны названия колонок после агрегации
Если я беру колонку, то как мне к ее элементам обращаться?
AS
Если я беру колонку, то как мне к ее элементам обращаться?
.collect()
IP
Колонка это вообще массив?
AS
Колонка это вообще массив?
нет
IP
нет
А что?
AS
А что?
колонка
IP
нет
Как обратиться к элементу колонки?
AS
Как обратиться к элементу колонки?
.collect()
AS
df.select("array").rdd.flatMap(lambda x: x).collect()
AS
ну скале по другому
IP
ну скале по другому
Что коллект вернет?
AS
Что коллект вернет?
почитайте документацию
RI
Что коллект вернет?
У тебя скала и idea там можно типы посмотреть
DM
а можно ссылку?
прошу прощения за мой альцгеймер, я в очередной раз спутал их стримы с коннектами (в последних немножко автматических штук добавлено и есть апиха)
AZ
прошу прощения за мой альцгеймер, я в очередной раз спутал их стримы с коннектами (в последних немножко автматических штук добавлено и есть апиха)
да, kafka connect в распределенном режиме это кластер application серверов с restful api и каким-никаким таск менеджментом