How to integrate Apache Spark with MySQL for reading database tables as a spark dataframe? [closed]

by

From pySpark, it work for me : 

dataframe_mysql = mySqlContext.read.format("jdbc").options(
    url="jdbc:mysql://localhost:3306/my_bd_name",
    driver = "com.mysql.jdbc.Driver",
    dbtable = "my_tablename",
    user="root",
    password="root").load()

More Related Contents:

  1. In Apache Spark 2.0.0, is it possible to fetch a query from an external database (rather than grab the whole table)?
  2. mysql_fetch_array() expects parameter 1 to be resource, boolean given in [closed]
  3. When I want to install MySQL I faced this issue “root account password” I forgot it
  4. How to perform grouped ranking in MySQL
  5. How to abort INSERT operation in MySql trigger?
  6. Restoring MySQL database from physical files
  7. Mysql or/and precedence?
  8. MySQL Trigger after update only if row has changed
  9. MySQL “WITH” clause
  10. MySQL Query – Records between Today and Last 30 Days
  11. MySQL “Group By” and “Order By”
  12. MySQL Query to select data from last week?
  13. ERROR 2003 (HY000): Can’t connect to MySQL server on ‘127.0.0.1’ (111)
  14. Migrate from Oracle to MySQL
  15. Which is more efficient: Multiple MySQL tables or one large table?
  16. #1139 – Got error ‘repetition-operator operand invalid’ from regexp
  17. How to skip columns in CSV file when importing into MySQL table using LOAD DATA INFILE?
  18. MySQL ‘user_id’ in where clause is ambiguous problem
  19. Images in MySQL
  20. What does it mean when MySQL is in the state “Sending data”?
  21. adding RMySQL package to R fails (on Windows)?
  22. How do I count columns of a table
  23. Mysqldump launched by cron and password security
  24. MySQL Trigger cannot update table – getting ERROR 1442
  25. MySQL delete duplicate records but keep latest
  26. Why MySQL is giving error “Not allowed to return a result set from a function”?
  27. Where I can find a list of “mysqldump” exit codes?
  28. Array data type, split string,
  29. Are there any functions in MySQL like dense_rank() and row_number() like Oracle?
  30. How can I make a table in MySQL called “order”?

Leave a Comment