CREATE DATABASE IF NOT EXISTS `hiveCatalogName`.`databaseName`;

CREATE TABLE IF NOT EXISTS `hiveCatalogName`.`databaseName`.`tableName` (
  user_id INT,
  item_id INT,
  category_id INT,
  -- ts AS localtimestamp,
  -- WATERMARK FOR ts AS ts,
  behavior VARCHAR
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '1', -- The number of records generated per second
  'fields.user_id.kind' = 'sequence', -- Whether a bounded sequence (if yes, the output automatically stops after the sequence ends)
  'fields.user_id.start' = '1', -- The start value of the sequence
  'fields.user_id.end' = '10000', -- The end value of the sequence
  'fields.item_id.kind' = 'random', -- A random number without range
  'fields.item_id.min' = '1', -- ‍The minimum random number
  'fields.item_id.max' = '1000', -- The maximum random number
  'fields.category_id.kind' = 'random', -- A random number without range
  'fields.category_id.min' = '1', -- The minimum random number
  'fields.category_id.max' = '1000', -- The maximum random number
  'fields.behavior.length' = '5' -- Random string length
);

INSERT INTO
  `hiveCatalogName`.`databaseName`.`sink_tableName` 
SELECT
  *
FROM
  `hiveCatalogName`.`databaseName`.`source_tableName`;