sql查询会转换为Zeppelin中的spark lang

Question

我尝试转移sql查询以激发lang。这是SQL查询：

%sql
select ${checkbox:fields=AGE|NAME|SEX} from table limit ${limit=10}

然后我转移spark lang：

%spark
var fields = z.select("fields", Seq(("AGE","AGE"),("NAME","NAME"),("SEX","SEX"))
val lim = z.input("limit","20")
df.selectExpr(fields).limit(lim).show()

但是它不起作用。如何收集？

Answer 1

您在这里错过了几件事。