Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagesql
-- 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
languagesql
'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'

...