Advertisement
Guest User

Untitled

a guest
Apr 8th, 2016
100
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.16 KB | None | 0 0
  1. spark.driver.extraClassPath /Users/<my_user>/spark-1.6.1-bin-hadoop2.4/lib/postgresql-9.4.1208.jre6.jar:/Users/<my_user>/spark-1.6.1-bin-hadoop2.4/lib/sqljdbc4.jar
  2.  
  3. wget https://download.microsoft.com/download/0/2/A/02AAE597-3865-456C-AE7F-613F99F850A8/sqljdbc_6.0.7130.100_enu.tar.gz
  4.  
  5. tar -xf sqljdbc_6.0.7130.100_enu.tar.gz
  6.  
  7. ls
  8.  
  9. ./spark/bin/pyspark --packages com.databricks:spark-csv_2.11:1.2.0 --driver-class-path "/root/sqljdbc_6.0/enu/sqljdbc4.jar"
  10.  
  11. sqlserver_user = <my_sql_user>
  12. sqlserver_pw = <my_sql_pw>
  13.  
  14. sqlserver_<my_database>_url = "jdbc:sqlserver://<my_server>.cloudapp.net:<port_num>;DatabaseName=<my_db>;user=<my_user>;password=<my_password>;"
  15.  
  16. my_jdbc_test = sqlContext.load(
  17. source="jdbc",
  18. url=sqlserver_<my_database>_url,
  19. dbtable=<my_table>
  20. )
  21.  
  22. my_jdbc_test.printSchema()
  23.  
  24. >>> my_jdbc_test.printSchema()
  25. root
  26. |-- my_var1: string (nullable = true)
  27. |-- my_var2: string (nullable = true)
  28. |-- my_var3: string (nullable = false)
  29.  
  30. >>>
  31.  
  32. my_jdbc_test.write.save("my_jdbc_test", format="parquet")
  33.  
  34. No suitable driver found for jdbc:sqlserver://<my_server>.cloudapp.net:<port_num>;DatabaseName=<my_db>;user=<my_user>;password=<my_password>;
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement