Advertisement
Guest User

Untitled

a guest
Nov 8th, 2017
78
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.31 KB | None | 0 0
  1. C:\ spark-shell -–driver-class-path /mysqlc/mysql-connector-java-5.1.43-bin.jar
  2.  
  3. val sqlContext = new org.apache.spark.sql.SQLContext(sc)
  4.  
  5. val jdbcDF = sqlContext.load("jdbc", Map("url" -> "jdbc:mysql://localhost:3306/dbupm?user=root&password=", "dbtable" -> "usermaster"))
  6.  
  7.  
  8. jdbcDF.count
  9.  
  10. jdbcDF.collect()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement