-- sparksql 连接mysql
// spark连接mysql:
val df = spark.read
.format("jdbc")
.option("url", "jdbc:mysql://152.159.0.74:3306/cluster1")
.option("dbtable", "CHL1")
.option("user", "root")
.option("password", "d123123")
.load()
-- sparksql 连接mysql
// spark连接mysql:
val df = spark.read
.format("jdbc")
.option("url", "jdbc:mysql://152.159.0.74:3306/cluster1")
.option("dbtable", "CHL1")
.option("user", "root")
.option("password", "d123123")
.load()
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
