2021 at 1:37 PM
To: "user@beam.apache.org" , Rui Wang
Subject: Re: Regarding the over window query support from Beam SQL
Hi Rui,
Yes that’s the problem. The alias is not propagated to the final schema.
Created https://issues.apache.org/jira/browse/BEAM-11930
Thanks!
From: Rui W
iu...@apache.org>>
Date: Tuesday, March 2, 2021 at 10:43 AM
To: Tao Li mailto:t...@zillow.com>>
Cc: "user@beam.apache.org<mailto:user@beam.apache.org>"
mailto:user@beam.apache.org>>
Subject: Re: Regarding the over window query support from Beam SQL
Hi Tao,
[1] contains wha
*Tao Li
> *Reply-To: *"user@beam.apache.org"
> *Date: *Tuesday, March 2, 2021 at 3:37 PM
> *To: *Rui Wang
> *Cc: *"user@beam.apache.org"
> *Subject: *Re: Regarding the over window query support from Beam SQL
>
>
>
> Hi Rui,
>
>
>
> Tha
ndow#0=[window(partition {0} order by [1] range between
UNBOUNDED PRECEDING and CURRENT ROW aggs [RANK()])])
BeamIOSourceRel(table=[[beam, PCOLLECTION]])
From: Rui Wang
Date: Tuesday, March 2, 2021 at 10:43 AM
To: Tao Li
Cc: "user@beam.apache.org"
Subject: Re: Regarding the over
rder by [1] range between
UNBOUNDED PRECEDING and CURRENT ROW aggs [RANK()])])
BeamIOSourceRel(table=[[beam, PCOLLECTION]])
From: Rui Wang
Date: Tuesday, March 2, 2021 at 10:43 AM
To: Tao Li
Cc: "user@beam.apache.org"
Subject: Re: Regarding the over window query support
Hi Tao,
[1] contains what functions are working with OVER clause. Rank is one of
the functions that is supported. Can you take a look?
[1]:
https://github.com/apache/beam/blob/master/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamAnalyticFunctionsTest.java
-Rui
O
+ Rui Wang. Looks like Rui has been working on this jira.
From: Tao Li
Date: Monday, March 1, 2021 at 9:51 PM
To: "user@beam.apache.org"
Subject: Regarding the over window query support from Beam SQL
Hi Beam community,
Querying over a window for ranking etc is pretty common in SQL use cases.
