O SparkSQL suporta subconsulta?
Estou executando esta consulta no shell Spark, mas isso gera um erro,
sqlContext.sql(
"select sal from samplecsv where sal < (select MAX(sal) from samplecsv)"
).collect().foreach(println)
erro:
java.lang.RuntimeException: [1.47] falha: ``) '' esperada, mas o identificador MAX encontrado
selecione sal de samplecsv em que sal <(selecione MAX (sal) de samplecsv) ^ em scala.sys.package $ .error (package.scala: 27) Alguém pode me explicar, obrigado