Errors

Classes

PySparkException ([消息, 错误类型, …])	用于处理来自 PySpark 的错误的基本异常。
AnalysisException ([消息, 错误类别, …])	分析 SQL 查询计划失败。
TempTableAlreadyExistsException ([消息， …])	无法创建临时视图，因为它已经存在。
ParseException ([消息, 错误类别, …])	无法解析SQL命令。
IllegalArgumentException ([消息, …])	传递了一个非法或不合适的参数。
StreamingQueryException ([消息, …])	停止 StreamingQuery 的异常。
QueryExecutionException ([消息, …])	执行查询失败。
PythonException ([信息, 错误类别, …])	从Python工作线程中抛出的异常。
UnknownException ([消息，错误类，…])	以上没有任何异常。
SparkUpgradeException ([消息， …])	由于Spark升级而抛出异常。

Methods

PySparkException.getErrorClass ()	返回一个错误类作为字符串。
PySparkException.getMessageParameters ()	返回一个消息参数字典。
PySparkException.getSqlState ()	返回一个作为字符串的SQLSTATE。

上一个

pyspark.resource.TaskResourceRequests

下一个

pyspark.errors.PySparkException