我使用的flink版本1.12.2。
有个问题请教一下,如何在flink sql 查询语句中将count值取出。
先举个例子:
val total: Int = hiveContext.sql("select count(*) from
a").collect()(0)(0).toString.toInt
可以把count值拿出来,那如果用flink sql去做的话 怎样取出查询后的结果呢。
1、是否flink sql可以这么做?
2、如果可以应该怎么写呢?

回复