U kunt hetzelfde doen met Scala. Gebruik JDBC (java.sql.{Connection,DriverManager} ) en krijg resultaatset.
Dat kan niet, want dit is geen Postgres-query. Wat u uitvoert in spark.sql is een Spark-query. Wat u kunt doen, is subquery gebruiken:
- Is het in Apache Spark 2.0.0 mogelijk om een query op te halen uit een externe database (in plaats van de hele tafel)?
- Hoe gebruik ik een SQL-query om een tabel in dbtable te definiëren?
Misschien voldoet het aan uw eisen (als de zoekopdracht niet dynamisch hoeft te zijn). Helaas ondersteunt Spark SQL ook geen geometrische typen, dus het kan zijn dat je het moet casten naar iets dat door Spark kan worden verbruikt of je eigen dialect moet definiëren.