1 from pyspark.sql.functions import spli […]">

python-无法在pyspark中导入parse_url

2021-01-08 27点热度 0人点赞 0条评论

我有这个SQL查询,用于pyspark中的hiveql:

spark.sql('SELECT split(parse_url(page.viewed_page, "PATH"), "/")[1] as path FROM df')

我想将其转换为如下函数查询:

df.select(split(parse_url(col('page.viewed_page'), 'HOST')))

但是当我导入abraham函数时,我得到:

----> 1 from pyspark.sql.functions import split, parse_url

ImportError: cannot import name 'parse_url' from 'pyspark.sql.functions' (/usr/local/opt/apache-spark/libexec/python/pyspark/sql/functions.py)

你能给我指出导入parse_url函数的正确方向吗?

干杯

查看隐藏内容需要支付:¥1
查看

未经允许不得转载!python-无法在pyspark中导入parse_url

本文地址:https://ans.52learn.online/2178

ANS52LEARN

DO BEST