Можете да направите същото със Scala. Използвайте JDBC (java.sql.{Connection,DriverManager} ) и вземете набор от резултати.
Не можете, защото това не е заявка на Postgres. Какво изпълнявате в spark.sql е заявка на Spark. Това, което можете да направите, е да използвате подзаявка:
- В Apache Spark 2.0.0 възможно ли е да извлечете заявка от външна база данни (вместо да вземете цялата таблица)?
- Как да използвам SQL заявка за дефиниране на таблица в dbtable?
Може би ще отговаря на вашите изисквания (ако заявката не трябва да е динамична). За съжаление Spark SQL също не поддържа геометрични типове, така че може да се наложи да го прехвърлите към нещо консумативно от Spark или да дефинирате свой собствен диалект.
