-- 1. Define the Paimon destination table
CREATE TABLE IF NOT EXISTS `116-paimon-sink1`.`default`.`HiveSink` ( 
    id INT PRIMARY KEY NOT ENFORCED,  -- Paimon requires a primary key, and `id` serves as the primary key.
    name STRING 
) WITH (
);
-- 2. Define the Hive source table
CREATE TABLE IF NOT EXISTS `hive116-1`.`default`.`source` (
  id INT,
  name STRING,
  dt STRING,
  hr STRING
) PARTITIONED BY (dt, hr)
WITH
    'connector' = 'hive',
    'hive-version' = '3.1.1',
    'hive-database' = 'default',
    'partition.time-extractor.timestamp-pattern'='$dt $hr:00:00',
    'sink.partition-commit.trigger'='partition-time',
    'sink.partition-commit.delay'='10 min',
    'sink.partition-commit.policy.kind'='metastore,success-file'
);


INSERT INTO `116-paimon-sink1`.`default`.`HiveSink`
SELECT 
    id, 
    `name` 
FROM `hive116-1`.`default`.`source`;