Dasselbe können Sie mit Scala tun. Verwenden Sie JDBC (java.sql.{Connection,DriverManager} ) und Ergebnismenge abrufen.
Das können Sie nicht, da dies keine Postgres-Abfrage ist. Was Sie in spark.sql ausführen ist eine Spark-Abfrage. Was Sie tun können, ist die Unterabfrage:
- Ist es in Apache Spark 2.0.0 möglich, eine Abfrage aus einer externen Datenbank abzurufen (anstatt Grab die ganze Tabelle)?
- Wie verwende ich eine SQL-Abfrage, um eine Tabelle in dbtable zu definieren?
Vielleicht passt es zu Ihren Anforderungen (wenn die Abfrage nicht dynamisch sein muss). Leider unterstützt Spark SQL auch keine geometrischen Typen, daher müssen Sie es möglicherweise in etwas umwandeln, das von Spark verwendet werden kann, oder Ihren eigenen Dialekt definieren.
