5
Ho un codice in cui ho bisogno di impostare tre tabelle. Per farlo devo chiamare la funzione jdbc
tre volte per ogni tabella. Vedi codice sottoCome specificare più tabelle in Spark SQL?
val props = new Properties
props.setProperty("user", "root")
props.setProperty("password", "pass")
val df0 = sqlContext.read.jdbc(
"jdbc:mysql://127.0.0.1:3306/Firm42", "company", props)
val df1 = sqlContext.read.jdbc(
"jdbc:mysql://127.0.0.1:3306/Firm42", "employee", props)
val df2 = sqlContext.read.jdbc(
"jdbc:mysql://127.0.0.1:3306/Firm42", "company_employee", props)
df0.registerTempTable("company")
df1.registerTempTable("employee")
df2.registerTempTable("company_employee")
val rdf = sqlContext.sql(
"""some_sql_query_with_joins_of_various_tables""".stripMargin)
rdf.show
È possibile semplificare il mio codice? O forse c'è un modo per specificare più tabelle da qualche parte nella configurazione SQL.
la risposta è stata di aiuto o preferisci risposte aggiuntive? – 030