Du kan gøre det samme med Scala. Brug JDBC (java.sql.{Connection,DriverManager} ) og få et resultatsæt.
Det kan du ikke, fordi dette ikke er en Postgres-forespørgsel. Hvad du udfører i spark.sql er en Spark-forespørgsel. Hvad du kan gøre er at bruge underforespørgsel:
- I Apache Spark 2.0.0 er det muligt at hente en forespørgsel fra en ekstern database (i stedet for at få fat i hele bordet)?
- Hvordan bruger jeg SQL-forespørgsel til at definere tabel i dbtable?
Måske vil det passe til dine krav (hvis forespørgslen ikke behøver at være dynamisk). Desværre understøtter Spark SQL heller ikke geometriske typer, så det kan være nødvendigt at caste det til noget, der kan forbruges af Spark eller definere din egen dialekt.