LLL
08/01/2024, 8:29 AM-- create connect table
CREATE TABLE default_catalog.default_database.`test_p` (
id BIGINT,
t BIGINT,
dt STRING,
ts AS CAST(TO_TIMESTAMP_LTZ(t, 3) AS TIMESTAMP(3)),
WATERMARK FOR ts AS ts - INTERVAL '5' SECOND
)
PARTITIONED BY (dt)
WITH (
'connector'='iceberg',
...
);
SET execution.runtime-mode = streaming;
SET table.dynamic-table-options.enabled = true;
/*+ OPTIONS('streaming'='true', 'monitor-interval'='15s')*/
-- Syntax error !
SELECT * FROM
TABLE (
TUMBLE(
TABLE test_p ,
DESCRIPTOR(ts),
INTERVAL '5' MINUTES
)
) /*+ OPTIONS('streaming'='true', 'monitor-interval'='15s')*/;