To samo możesz zrobić ze Scali. Użyj JDBC (java.sql.{Connection,DriverManager} ) i uzyskaj zestaw wyników.
Nie możesz, ponieważ to nie jest zapytanie Postgres. Co wykonujesz w spark.sql to zapytanie Spark. Możesz użyć podzapytania:
- Czy w Apache Spark 2.0.0 możliwe jest pobranie zapytania z zewnętrznej bazy danych (zamiast cały stół)?
- Jak użyć zapytania SQL do zdefiniowania tabeli w dbtable?
Może będzie pasować do Twoich wymagań (jeśli zapytanie nie musi być dynamiczne). Niestety Spark SQL również nie obsługuje typów geometrycznych, więc może być konieczne rzucenie go na coś, co może być używane przez Spark lub zdefiniowanie własnego dialektu.
