Anda dapat melakukan hal yang sama dengan Scala. Gunakan JDBC (java.sql.{Connection,DriverManager} ) dan dapatkan hasil yang ditetapkan.
Anda tidak bisa, karena ini bukan kueri Postgres. Apa yang Anda jalankan di spark.sql adalah kueri Spark. Yang dapat Anda lakukan adalah menggunakan subquery:
- Di Apache Spark 2.0.0, apakah mungkin mengambil kueri dari database eksternal (bukan mengambil seluruh tabel)?
- Bagaimana cara menggunakan kueri SQL untuk mendefinisikan tabel di dbtable?
Mungkin itu akan sesuai dengan kebutuhan Anda (jika kueri tidak harus dinamis). Sayangnya Spark SQL juga tidak mendukung tipe geometris, jadi mungkin harus mentransmisikannya ke sesuatu yang dapat dikonsumsi oleh Spark atau menentukan dialek Anda sendiri.
