flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jark Wu <imj...@gmail.com>
Subject Re: two phase aggregation
Date Tue, 23 Jun 2020 04:35:52 GMT
Hi Fanbin,

Currently, over window aggregation doesn't support two-phase optimization.

Best,
Jark

On Tue, 23 Jun 2020 at 12:14, Fanbin Bu <fanbin.bu@coinbase.com> wrote:

> Hi,
>
> Does over window aggregation support two-phase mode?
>
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/config.html#table-optimizer-agg-phase-strategy
>
> SELECT
>   user_id
>   , event_time
>   , listagg(event_type, '*') over w as names
> FROM table
> WINDOW w AS
> ( PARTITION BY user_id
>   ORDER BY event_time
>   ROWS BETWEEN 256 PRECEDING AND CURRENT ROW
> )
>
>

Mime
View raw message