如何注冊一個JDBC火花方言在Python中?

[User16765131552]

我想從一個磚表讀取。我已經使用url從磚的集群。我得到這個錯誤:

java.sql。SQLDataException(辛巴):(JDBC)(10140)錯誤將值轉換為int。

在這些語句:

jdbcConnUrl = " jdbc:火花:/ /亞行.....”testquery = " (select *從db。表3)限製“testdf = spark.read.format (jdbc)。選項(“url”, jdbcConnUrl)。選項(“數據表”,testquery)。選項(“fetchsize”、“10000”) .load () testdf.show ()

我遇到過所有Scala解決這個問題但是我使用python。我想要一個python相當於這段代碼:

進口org.apache.spark.sql.jdbc。{JdbcDialect, JdbcDialects} JdbcDialects。registerDialect(新JdbcDialect(){覆蓋def canHandle (url:字符串):布爾= url.toLowerCase.startsWith (" jdbc:火花:")覆蓋def quoteIdentifier(列:String):字符串列}=)

[Kaniz]

你好@User16217864942579505928!我的名字叫Kaniz,和我是一個技術主持人。很高興認識你,謝謝你的問題!看看你的同行在論壇上先回答你的問題。否則我們將很快跟進與回複。

[imstwz1]

嗨@Brad鮑威爾,在Python中你能解決這個問題。我也與這個問題在python中,解決方案隻有在Scala中,需要在python中這個解決方案。你能幫我解決這個問題。謝謝

[Meghala]

這是經驗謝謝

[Yadu]

嗨@Brad鮑威爾/ @Kaniz Fatma / @ Meghala——任何更新嗎?