THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
-- configure in table options CREATE TABLE user_actions ( ... user_action_time TIMESTAMP(3), WATERMARK FOR user_action_time AS user_action_time - INTERVAL '5' SECOND ) WITH ( 'watermarksource.idle-timeout'='1min', ... ); -- use 'OPTIONS' hint select ... from source_table /*+ OPTIONS('watermarksource.idle-timeout'='1min') */ |
...
Code Block | ||
---|---|---|
| ||
'watermark.emit.strategy'='ON_EVENT', 'watermark.emit.gap.on-event'='10000', 'watermarksource.idle-timeout'='1min', 'watermark.alignment.group'='alignment-group-1', 'watermark.alignment.max-drift'='1min', 'watermark.alignment.update-interval'='1s' |
...