स्पार्क एसक्यूएल में एसक्यूएल क्वेरी का उपयोग करके जेडीबीसी स्रोत से डेटा पढ़ने के लिए, आप कुछ इस तरह से कोशिश कर सकते हैं:
val df_table1 = sqlContext.read.format("jdbc").options(Map(
("url" -> "jdbc:postgresql://localhost:5432/mydb"),
("dbtable" -> "(select * from table1) as table1"),
("user" -> "me"),
("password" -> "******"),
("driver" -> "org.postgresql.Driver"))
).load()
मैंने PostgreSQL का उपयोग करके इसे आजमाया। आप इसे MySQL
. के अनुसार संशोधित कर सकते हैं ।