spark连接jdbc
spark提供了一个JdbcRDD来进行连接数据库
1
2
3
4
5
6
| def createConnection() ={
Class.forName("com.mysql.jdbc.Driver").newInstance()
DriverManager.getConnection("jdbc:mysql://localhost/test")
}
val datas = new JdbcRDD(sc, createConnection(), "select * from user")
|