回复：flink table API使用

[小昌同学 <cc...@163.com>]

感谢感谢大佬指点


| |
应聘者昌呈呈
|
|
ccc0606fighting@163.com
|
---- 回复的原邮件 ----
| 发件人 | Xuyang<xy...@163.com> |
| 发送日期 | 2022年9月6日 00:03 |
| 收件人 | <us...@flink.apache.org> |
| 主题 | Re:flink table API使用 |
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，"小昌同学" <cc...@163.com> 写道：


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算子咋用呀
| |
小昌
|
|
ccc0606fighting@163.com
|