Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
- wget https://download.microsoft.com/download/0/2/A/02AAE597-3865-456C-AE7F-613F99F850A8/sqljdbc_6.0.7130.100_enu.tar.gz
- tar -xf sqljdbc_6.0.7130.100_enu.tar.gz
- ls
- ./spark/bin/pyspark --packages com.databricks:spark-csv_2.11:1.2.0 --driver-class-path "/root/sqljdbc_6.0/enu/sqljdbc4.jar"
- sqlserver_user = <my_sql_user>
- sqlserver_pw = <my_sql_pw>
- sqlserver_<my_database>_url = "jdbc:sqlserver://<my_server>.cloudapp.net:<port_num>;DatabaseName=<my_db>;user=<my_user>;password=<my_password>;"
- my_jdbc_test = sqlContext.load(
- source="jdbc",
- url=sqlserver_<my_database>_url,
- dbtable=<my_table>
- )
- my_jdbc_test.printSchema()
- >>> my_jdbc_test.printSchema()
- root
- |-- my_var1: string (nullable = true)
- |-- my_var2: string (nullable = true)
- |-- my_var3: string (nullable = false)
- >>>
- my_jdbc_test.write.save("my_jdbc_test", format="parquet")
- 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