Puoi fare lo stesso con Scala. Usa JDBC (java.sql.{Connection,DriverManager} ) e ottieni il set di risultati.
Non puoi, perché questa non è una query Postgres. Cosa esegui in spark.sql è una query Spark. Quello che puoi fare è usare la sottoquery:
- In Apache Spark 2.0.0, è possibile recuperare una query da un database esterno (piuttosto che afferrare tutta la tavola)?
- Come utilizzare la query SQL per definire la tabella in dbtable?
Forse si adatta alle tue esigenze (se la query non deve essere dinamica). Sfortunatamente Spark SQL non supporta nemmeno i tipi geometrici, quindi potrebbe essere necessario eseguirne il cast su qualcosa di consumabile da Spark o definire il tuo dialetto.
