ޚj:ddlmZddlmZGddeZGddeZGdd eZGd d eZGd d eZ GddeZ GddeZ GddeZ GddeZ GddeZGdde ZGddeZGddeZGddeZGd d!eZGd"d#eZGd$d%eZGd&d'eeZGd(d)eeZGd*d+eeZGd,d-eeZGd.d/eeZGd0d1ee Z!Gd2d3ee"Z#y4)5)cast)ErrorClassesReaderc eZdZdZ d dedzdedzdeeefdzddfdZdedzfdZdeeefdzfd Zd d Z defd Z y)PySparkExceptionz:Base Exception for handling errors generated from PySpark.Nmessage error_classmessage_parametersreturnc||||||Jt|_|6|jjtd|td||_n||_||_||_y)Nstrzdict[str, str])r error_readerget_error_messagerrr r )selfrr r s sC:\Users\Luka\AppData\Local\Temp\pip-target-o84fipzb\lib\python\duckdb/experimental/spark/errors/exceptions/base.py__init__zPySparkException.__init__ s#)>UK($/?AS*TDL#DL&"4c|jS)zReturns an error class as a string. .. versionadded:: 3.4.0 See Also: -------- :meth:`PySparkException.getMessageParameters` :meth:`PySparkException.getSqlState` )r rs r getErrorClasszPySparkException.getErrorClass"src|jS)zReturns a message parameters as a dictionary. .. versionadded:: 3.4.0 See Also: -------- :meth:`PySparkException.getErrorClass` :meth:`PySparkException.getSqlState` )r rs rgetMessageParametersz%PySparkException.getMessageParameters.s&&&rcy)a$Returns an SQLSTATE as a string. Errors generated in Python have no SQLSTATE, so it always returns None. .. versionadded:: 3.4.0 See Also: -------- :meth:`PySparkException.getErrorClass` :meth:`PySparkException.getMessageParameters` Nrs r getSqlStatezPySparkException.getSqlState:srcz|j d|jd|jS|jS)N[z] )rrrs r__str__zPySparkException.__str__Hs<     +t))+,Bt||n= =<< r)NNN)r N) __name__ __module__ __qualname____doc__r dictrrrrrrrrrrsD#"&48 5t54Z 5 !cNT1 5 52  sTz   'd38nt&; '   rrceZdZdZy)AnalysisExceptionz#Failed to analyze a SQL query plan.Nrr r!r"rrrr%r%Os-rr%ceZdZdZy)SessionNotSameExceptionz7Performed the same operation on different SparkSession.Nr&rrrr(r(SsArr(ceZdZdZy)TempTableAlreadyExistsExceptionz6Failed to create temp view since it is already exists.Nr&rrrr*r*W@rr*ceZdZdZy)ParseExceptionzFailed to parse a SQL command.Nr&rrrr-r-[s(rr-ceZdZdZy)IllegalArgumentExceptionz,Passed an illegal or inappropriate argument.Nr&rrrr/r/_s6rr/ceZdZdZy)ArithmeticExceptionz;Arithmetic exception thrown from Spark with an error class.Nr&rrrr1r1csErr1ceZdZdZy)UnsupportedOperationExceptionzFUnsupported operation exception thrown from Spark with an error class.Nr&rrrr3r3gsPrr3ceZdZdZy)ArrayIndexOutOfBoundsExceptionzJArray index out of bounds exception thrown from Spark with an error class.Nr&rrrr5r5ksTrr5ceZdZdZy)DateTimeExceptionz9Datetime exception thrown from Spark with an error class.Nr&rrrr7r7osCrr7ceZdZdZy)NumberFormatExceptionz>Number format exception thrown from Spark with an error class.Nr&rrrr9r9ssHrr9ceZdZdZy)StreamingQueryExceptionz1Exception that stopped a :class:`StreamingQuery`.Nr&rrrr;r;ws;rr;ceZdZdZy)QueryExecutionExceptionzFailed to execute a query.Nr&rrrr=r={s$rr=ceZdZdZy)PythonExceptionz&Exceptions thrown from Python workers.Nr&rrrr?r?s0rr?ceZdZdZy)SparkRuntimeExceptionz8Runtime exception thrown from Spark with an error class.Nr&rrrrArABrrAceZdZdZy)SparkUpgradeExceptionz*Exception thrown because of Spark upgrade.Nr&rrrrDrDs4rrDceZdZdZy)UnknownExceptionzNone of the above exceptions.Nr&rrrrFrFs'rrFceZdZdZy)PySparkValueErrorz6Wrapper class for ValueError to support error classes.Nr&rrrrHrHr+rrHceZdZdZy)PySparkIndexErrorz6Wrapper class for IndexError to support error classes.Nr&rrrrJrJr+rrJceZdZdZy)PySparkTypeErrorz5Wrapper class for TypeError to support error classes.Nr&rrrrLrLs?rrLceZdZdZy)PySparkAttributeErrorz:Wrapper class for AttributeError to support error classes.Nr&rrrrNrNDrrNceZdZdZy)PySparkRuntimeErrorz8Wrapper class for RuntimeError to support error classes.Nr&rrrrQrQrBrrQceZdZdZy)PySparkAssertionErrorz:Wrapper class for AssertionError to support error classes.Nr&rrrrSrSrOrrSceZdZdZy)PySparkNotImplementedErrorz?Wrapper class for NotImplementedError to support error classes.Nr&rrrrUrUsIrrUN)$typingrutilsr Exceptionrr%r(r*r-r/r1r3r5r7r9r;r=r?rArDrF ValueErrorrH IndexErrorrJ TypeErrorrLAttributeErrorrN RuntimeErrorrQAssertionErrorrSNotImplementedErrorrUrrrr`sr&F yF R.(.B.BA&7A)&)7/7F*FQ$4QU%5UD(DI4I<.<%.%1&1C,C5,5('(A(*AA(*A@'@E,nEC*LCE,nEJ!13FJr