Hi,
1. I do not have up to date knowledge, but Beam sql was missing quite a
lot of things regarding Calcite full support. I think the current way is
to create a feature request on repository and get votes and interest. I
definitely would vote for You initiative ;)
2. Regarding the query itself I got it working for something like this:
```
WITHcte AS(
SELECTCAST(event_datetime ASTIMESTAMP) ASts
FROMPCOLLECTION
)
SELECT
CAST(TUMBLE_START(cte.ts, INTERVAL '1'MINUTE) ASVARCHAR) ASstart_time,
CAST(TUMBLE_END(cte.ts, INTERVAL '1'MINUTE) ASVARCHAR) ASend_time,
COUNT(*) ASpage_views
FROMcte
GROUP BY
TUMBLE(cte.ts, INTERVAL '1'MINUTE)
;
```
Maybe it would be useful for you. Note that I am not up to date with
recent versions of Beam SQL, but I will need to catch up (the syntax for
defining window on table is cool).
Best
Wiśniowski Piotr
On 4.03.2024 05:27, Jaehyeon Kim wrote:
Hello,
I just tried a simple tumbling window but failed with the following error
RuntimeError: org.apache.beam.sdk.extensions.sql.impl.ParseException:
Unable to parse query
WITH cte AS (
SELECT TO_TIMESTAMP(event_datetime) AS ts FROM PCOLLECTION
)
SELECT
CAST(window_start AS VARCHAR) AS start_time,
CAST(window_end AS VARCHAR) AS end_time,
COUNT(*) AS page_views
FROM TABLE(
TUMBLE(TABLE cte, DESCRIPTOR(ts), 'INTERVAL 1 MINUTE')
)
GROUP BY
window_start, window_end
I guess it is because TO_TIMESTAMP is not implemented. When I check
the document, it misses lots of functions. Is there any roadmap about
Calcite support on Beam SQL?
Cheers,
Jaehyeon
