flink table API使用

[小昌同学]

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