Vous pouvez faire la même chose avec Scala. Utilisez JDBC (java.sql.{Connection,DriverManager} ) et obtenir le jeu de résultats.
Vous ne pouvez pas, car il ne s'agit pas d'une requête Postgres. Ce que vous exécutez dans spark.sql est une requête Spark. Ce que vous pouvez faire est d'utiliser la sous-requête :
- Dans Apache Spark 2.0.0, est-il possible d'extraire une requête d'une base de données externe (plutôt que de saisir toute la table) ?
- Comment utiliser une requête SQL pour définir une table dans dbtable ?
Peut-être que cela répondra à vos besoins (si la requête n'a pas besoin d'être dynamique). Malheureusement, Spark SQL ne prend pas non plus en charge les types géométriques, vous devrez donc peut-être le convertir en quelque chose consommable par Spark ou définir votre propre dialecte.
