python - 如何在 PySpark 中导入 AnalysisException
问题描述
我找不到如何AnalysisException
在 PySpark 中导入,所以我可以抓住它。例如:
df = spark.createDataFrame([[1, 2], [1, 2]], ['A', 'A'])
try:
df.select('A')
except AnalysisException as e:
print(e)
错误信息:
NameError: name 'AnalysisException' is not defined
解决方案
你可以在这里导入它:
from pyspark.sql.utils import AnalysisException
这显示在错误回溯中,例如
Traceback (most recent call last):
...
File "<string>", line 3, in raise_from
pyspark.sql.utils.AnalysisException: cannot resolve ...
推荐阅读
- php - 如何在 PHP Codeigniter 中下载上传的图像
- python - 带有“添加图像”选项的 Python 菜单
- android - 我如何知道我在 Wi-Fi Direct(Android) 中使用的标准 Wi-Fi (802.11)?
- python - 将 POST 请求重定向到已使用的 URL (Django)
- excel - 条件格式中的格式条件
- macos - 在 Mojave 上安装 Brew
- javascript - 测试具有多个承诺的 Jest 方法
- ruby-on-rails - redirect_to 在 Ruby on Rails 中不起作用
- haskell - 推导后什么时候应该加括号?
- javascript - 一个外部脚本 javascript 的多个页面 html 的变量