如何正确导入pyspark.sql.functions?

sqyvllje  于 2024-01-06  发布在  Spark
关注(0)|答案(3)|浏览(217)

第一个月
添加所有内容非常麻烦。有没有一种方法可以一次性导入所有内容?

s1ag04yj

s1ag04yj1#

你可以尝试使用from pyspark.sql.functions import *。这种方法可能会导致命名空间覆盖,比如pyspark sum函数覆盖python内置的sum函数。
另一种保险方法:import pyspark.sql.functions as F,使用方法:F.sum

0vvn1miw

0vvn1miw2#

简单地说:

  1. import pyspark.sql.functions as f

字符串
并将其用作:

  1. f.sum(...)
  2. f.to_date(...)

pxyaymoc

pxyaymoc3#

doc中,建议导入为import pyspark.sql.functions as sf

相关问题