Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val sqlContext = SparkSession.builder().appName("GenerateEventsSql").getOrCreate()
- val jdbcSqlConnStr = "jdbc:sqlserver://someserver.database.windows.net:1433;databaseName=myDW;user=admin;password=XXXX;"
- val tableName = "dbo.SomeTable"
- val allTableData = sqlContext.read.format("jdbc")
- .options(Map(
- "driver" -> "com.microsoft.sqlserver.jdbc.SQLServerDriver",
- "url" -> jdbcSqlConnStr, "dbtable" -> tableName)
- )
- .load()
Add Comment
Please, Sign In to add comment