【发布时间】:2018-08-28 02:46:02
【问题描述】:
我想使用collect_list:
from pyspark.sql.functions import collect_list
但是函数包没有collect_list只有_collect_list_doc
【问题讨论】:
标签: python pyspark pyspark-sql
我想使用collect_list:
from pyspark.sql.functions import collect_list
但是函数包没有collect_list只有_collect_list_doc
【问题讨论】:
标签: python pyspark pyspark-sql
像这样从 sql 中导入函数:
from pyspark.sql import functions as F
然后你可以使用 F.collect_set("field_name")
【讨论】:
collect_list即可生效,没有import