问如何在PySpark中添加MySQL详细信息作为属性？
EN

Stack Overflow用户

提问于 2021-02-08 18:05:21

回答 1查看 26关注 0票数 0

创建SparkSession时，因为有一个用于连接到Cassandra的属性，称为

.config("spark.cassandra.connection.host", "ip-address")

可以在创建SparkSession时直接添加，我们可以添加类似这样的MySQL细节，这样我们就可以避免在每个Spark函数中传递它们吗？

回答已采纳

发布于 2021-02-08 18:53:40

不，连接到MySQL时没有此选项。Cassandra有自己的spark-cassandra-connector，而对于MySQL，它使用JDBC，这需要将连接参数作为Java Properties传递。

它们在配置选项和工作方式上有所不同。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/66099479

复制

相似问题

问如何在PySpark中添加MySQL详细信息作为属性？EN