Hi,
I have been trying out spark data source api with JDBC. The following is
the code to get DataFrame,
Try(hc.load("org.apache.spark.sql.jdbc",Map("url" -> dbUrl,"dbtable"->s"($
query) ")))
By looking at test cases, I found that query has to be inside brackets,
otherwise it's treated as table name. But with when used with MySQL, query
inside the ( ) is treated as derived table which is throwing exception. Is
this the right way to pass the queries to jdbc source or am I missing
something?
Regards,
Madhukara Phatak
http://datamantra.io/
