flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fanbin Bu <fanbin...@coinbase.com>
Subject Re: two phase aggregation
Date Tue, 23 Jun 2020 05:09:39 GMT
Jark,
thanks for the reply. Do you know whether it's on the roadmap or what's the
plan?

On Mon, Jun 22, 2020 at 9:36 PM Jark Wu <imjark@gmail.com> wrote:

> 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