Scalaでも同じことができます。 JDBCを使用します(java.sql.{Connection,DriverManager}
)そして結果セットを取得します。
これはPostgresクエリではないため、できません。 spark.sql
で実行する内容 Sparkクエリです。できることは、サブクエリを使用することです:
多分それはあなたの要件に合うでしょう(クエリが動的である必要がない場合)。残念ながら、Spark SQLは幾何学的型もサポートしていないため、Sparkが消費できるものにキャストするか、独自の方言を定義する必要がある場合があります。