Guest User

Untitled

a guest
Nov 16th, 2017
101
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.62 KB | None | 0 0
  1. #!/bin/sh
  2. spark-shell
  3. import org.apache.spark.sql.SparkSession
  4. val url="jdbc:mysql://localhost:3306/slow_and_tedious"
  5. val prop = new java.util.Properties
  6. prop.setProperty("user",”scalauser”)
  7. prop.setProperty("password","scalauser123")
  8. val people = spark.read.jdbc(url,"sat",prop)
  9.  
  10. import org.apache.spark.sql.SparkSession
  11. val url="jdbc:mysql://localhost:3306/slow_and_tedious"
  12. val prop = new java.util.Properties
  13. prop.setProperty("user",”scalauser”)
  14. prop.setProperty("password","scalauser123")
  15. val people = spark.read.jdbc(url,"sat",prop)
  16.  
  17. spark-shell --jars mysql-connector.jar
  18.  
  19. scala> :load /path/test.scala
Add Comment
Please, Sign In to add comment