如何将flink sql 查询语句的count值取出

[张锴]

我使用的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、如果可以应该怎么写呢？

[guoyb]

可以看看这个demo


https://github.com/bingoguo93/flink-1.12-sql-demo/blob/main/src/main/java/org/example/mysql/tableQueryMysql.java



---原始邮件---
发件人: "张锴"<[hidden email]&gt;
发送时间: 2021年4月21日(周三) 中午11:24
收件人: "user-zh"<[hidden email]&gt;;
主题: 如何将flink sql 查询语句的count值取出


我使用的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、如果可以应该怎么写呢？