¿SparkSQL admite subconsultas?
Estoy ejecutando esta consulta en Spark Shell pero me da un error,
sqlContext.sql(
"select sal from samplecsv where sal < (select MAX(sal) from samplecsv)"
).collect().foreach(println)
error:
java.lang.RuntimeException: [1.47] error: ``) '' esperado pero identificador MAX encontrado
seleccione sal de samplecsv donde sal <(seleccione MAX (sal) de samplecsv) ^ en scala.sys.package $ .error (package.scala: 27) ¿Alguien puede explicarme, gracias