Не удается разрешить символ при попытке использовать функцию агрегирования искр

Question

Я хочу попробовать что-то вроде

Однако я получил предупреждение от идеи вроде

что мне делать?

Answer 1

Ваше заявление на импорт должно быть import org.apache.spark.sql.functions._

, где ._ - импорт с подстановочными знаками.org.apache.spark.sql.functions объект определяет встроенные стандартные функции для работы.

Затем вы можете использовать такие функции, как это:

df.groupBy(df("pt")).agg(max("id"), mean("encodedType")).show

Вы можете проверить пример по этой ссылке