- 说明:
/*
需要引入依赖
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.18</version>
</dependency>
*/
- 代码:
object MySQLToDataFrame {
def main(args: Array[String]): Unit = {
val sc = new SparkConf().setMaster("local[2]").setAppName("demo")
val session = SparkSession.builder().config(sc).getOrCreate()
val properties = new Properties()
properties.put("driver", "com.mysql.cj.jdbc.Driver")
properties.put("user", "root")
properties.put("password", "Jsq123456...")
val dataFrame = session.read.jdbc("jdbc:mysql://node1:3306/project?serverTimeznoe=UTC", "area_pvs", properties)
dataFrame.show()
}
}
原文地址:https://www.cnblogs.com/jsqup/p/16630334.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。