Table result = kafka_item.groupBy($("trans_number"))
.select($("trans_number"),$("sales_amount").sum().as("sum_amount"))
.filter($("sum_amount "));
各位大佬 请教一个问题 我这边想通过flink table API 达到这样一个效果：
根据trans_number进行分组 然后对另一个字段进行sum计算 然后我想最后进行过滤的时候 过滤出来这个sum值大于100的
我这个后续怎么使用API啊 这个filter算子
Hi, 可以类似这样写 “.filter($("a").isGreater(10)) "。 更多的使用方法可以参考[1]
[1]
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/GettingStartedExample.java
--
Best！
Xuyang
在 2022-09-05 20:53:03，"小昌同学"
退订
Sent from my iPhone
感谢感谢大佬指点
| |
应聘者昌呈呈
|
|
ccc0606fight...@163.com
|
回复的原邮件
| 发件人 | Xuyang |
| 发送日期 | 2022年9月6日 00:03 |
| 收件人 | |
| 主题 | Re:flink table API使用 |
Hi, 可以类似这样写 “.filter($("a").isGreater(10)) "。 更多的使用方法可以参考[1]
[1]
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-t
