You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Pinjie Huang <pi...@afterpay.com.INVALID> on 2021/12/14 07:47:26 UTC

Flink SQL 有办法access State吗

之前的DataStream API 我们可以通过State进行一些复杂的逻辑。比如所有message的某个field的最大值。Flink
SQL有类似的方法吗？

Re: Flink SQL 有办法access State吗

Posted by Caizhi Weng <ts...@gmail.com>.

Hi！

可以用 SQL 的聚合函数 [1] 实现。内置聚合函数详见 [2]，也可以自定义聚合函数，详见 [3]。

[1]
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/sql/queries/group-agg/
[2]
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/functions/systemfunctions/#%E8%81%9A%E5%90%88%E5%87%BD%E6%95%B0
[3]
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/functions/udfs/#%E8%81%9A%E5%90%88%E5%87%BD%E6%95%B0

Pinjie Huang <pi...@afterpay.com.invalid> 于2021年12月14日周二 15:48写道：

> 之前的DataStream API 我们可以通过State进行一些复杂的逻辑。比如所有message的某个field的最大值。Flink
> SQL有类似的方法吗？
>