मैंने इसे यहां पाया>
डीबीनाम पैरामीटर उपनाम के साथ कोष्ठक में लपेटा गया कोई भी प्रश्न हो सकता है। तो मेरे मामले में, मुझे यह करने की ज़रूरत है:
val query = """
(select dl.DialogLineID, dlwim.Sequence, wi.WordRootID from Dialog as d
join DialogLine as dl on dl.DialogID=d.DialogID
join DialogLineWordInstanceMatch as dlwim on dlwim.DialogLineID=dl.DialogLineID
join WordInstance as wi on wi.WordInstanceID=dlwim.WordInstanceID
join WordRoot as wr on wr.WordRootID=wi.WordRootID
where d.InSite=1 and dl.Active=1
limit 100) foo
"""
val df = sqlContext.format("jdbc").
option("url", "jdbc:mysql://localhost:3306/local_content").
option("driver", "com.mysql.jdbc.Driver").
option("useUnicode", "true").
option("continueBatchOnError","true").
option("useSSL", "false").
option("user", "root").
option("password", "").
option("dbtable",query).
load()
जैसा कि अपेक्षित था, प्रत्येक तालिका को अपने स्वयं के डेटाफ़्रेम के रूप में लोड करना और उन्हें स्पार्क में शामिल करना बहुत अक्षम था।
