Re:flink table API使用

Mon, 05 Sep 2022 09:02:40 -0700 

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

回复