Paimon集成

本文提供Paimon集成场景的实施思路、配置示例和验证方式，可作为实际项目配置参考。

案例

Paimon在本地中建表，插入数据，查询数据

解决方案

创建Flink SQL作业类型，添加以下依赖

• paimon-flink-1.18-1.1-20250124.002530-34.jar下载
• flink-shaded-hadoop-2-uber-2.8.3-10.0.jar下载

建表，插入数据

CREATE CATALOG my_catalog WITH (
    'type'='paimon',
    'warehouse'='file:/Users/ispong/Downloads/paimon'
);

USE CATALOG my_catalog;

CREATE TABLE word_count (
    word STRING PRIMARY KEY NOT ENFORCED,
    cnt BIGINT
) WITH (
    'file.format' = 'csv' 
);

INSERT INTO word_count
values ('张三', 13);

查询数据

CREATE CATALOG my_catalog WITH (
    'type'='paimon',
    'warehouse'='file:/Users/ispong/Downloads/paimon'
);

USE CATALOG my_catalog;

CREATE TEMPORARY TABLE print_sink ( 
    username string not null,
    age bigint
) WITH ( 
    'connector' = 'print' 
);

insert into print_sink select * from word_count ;