Advertisement
Guest User

Untitled

a guest
Aug 30th, 2017
68
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.69 KB | None | 0 0
  1. spark
  2. .read
  3. .format("jdbc")
  4. .option("url", "jdbc:mysql://localhost:3306/mydb")
  5. .option("driver", "com.mysql.jdbc.Driver")
  6. .option("dbtable", "mydb")
  7. .option("user", "root")
  8. .option("password", "")
  9. .load()
  10.  
  11. val spark = SparkSession.builder().appName("MyApp").master("local[*]").getOrCreate()
  12.  
  13. val loadedData=spark
  14. .read
  15. .format("jdbc")
  16. .option("url", "jdbc:mysql://localhost:3306/mydatabase")
  17. .option("driver", "com.mysql.jdbc.Driver")
  18. .option("mytable", "mydatabase")
  19. .option("user", "root")
  20. .option("password", "toor")
  21. .load().createOrReplaceTempView("mytable")
  22.  
  23. val dataFrame=spark.sql("Select * from mytable")
  24. dataFrame.show()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement