Du kan göra samma sak med Scala. Använd JDBC (java.sql.{Connection,DriverManager} ) och få ett resultat.
Du kan inte, eftersom detta inte är en Postgres-fråga. Vad du kör i spark.sql är en Spark-fråga. Vad du kan göra är att använda subquery:
- I Apache Spark 2.0.0 är det möjligt att hämta en fråga från en extern databas (istället för att ta tag i hela tabellen)?
- Hur använder jag SQL-fråga för att definiera tabell i dbtable?
Kanske passar det dina krav (om frågan inte behöver vara dynamisk). Tyvärr stöder Spark SQL inte heller geometriska typer, så du kan behöva casta den till något förbrukningsbart av Spark eller definiera din egen dialekt.