如何解决如何在 Python 中注册 JDBC Spark 方言?
我正在尝试从数据块表中读取数据。我在数据块中使用了集群中的 url。我收到此错误:
java.sql.sqlDataException: [Simba][JDBC](10140) Error converting value to int.
在这些陈述之后:
jdbcConnUrl= "jdbc:spark://adb....."
testquery="(select * from db.table limit 3)"
testdf=spark.read.format("jdbc").option("url",jdbcConnUrl).option("dbtable",testquery).option("fetchsize","10000").load()
testdf.show()
我遇到了针对此问题的所有 Scala 解决方案,但我使用的是 python。 我想要一个与此代码等效的python:
import org.apache.spark.sql.jdbc.{JdbcDialect,JdbcDialects}
JdbcDialects.registerDialect(new JdbcDialect() {
override def canHandle(url: String): Boolean = url.toLowerCase.startsWith("jdbc:spark:")
override
def quoteIdentifier(column: String): String = column
})
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。