SparkSQL поддерживает подзапрос?

Я выполняю этот запрос в оболочке Spark, но он дает мне ошибку,

sqlContext.sql(
 "select sal from samplecsv where sal < (select MAX(sal) from samplecsv)"
).collect().foreach(println)

ошибка:

java.lang.RuntimeException: [1.47] сбой: ``) '' ожидается, но идентификатор MAX найден

выберите sal из samplecsv, где sal <(выберите MAX (sal) из samplecsv) ^ в scala.sys.package $ .error (package.scala: 27) Может кто-нибудь объяснить мне, спасибо

Ответы на вопрос(2)

Ваш ответ на вопрос