#快速开始

-- 创建 catalog，注意替换 s3 endpoint 地址
CREATE CATALOG mycatalog WITH (
    'type'='paimon',
    'warehouse'='s3://gravitino/gravitino/paimon/',
    's3.endpoint' = 'http://localhost:9000',
    's3.access-key' = 'admin',
    's3.secret-key' = 'password'
);

-- 创建 paimon sink 表，在 paimon catalog 下无需指定 connector 为 paimon 和 path
CREATE TABLE mycatalog.`default`.word_count (
    word STRING PRIMARY KEY NOT ENFORCED,
    cnt BIGINT
);

-- 创建 source 表
CREATE TABLE vvp.`default`.word_table (
    word STRING
) WITH (
    'connector' = 'datagen',
    'fields.word.length' = '1'
);

-- 像 paimon 中写入数据，执行插入
INSERT INTO mycatalog.`default`.word_count SELECT word, COUNT(*) FROM vvp.`default`.word_table GROUP BY word;


-- 查询 paimon 数据
select * from mycatalog.`default`.word_count;