【Apache Paimon】-- 5 -- Flink 向 Paimon 表写入数据
目录
1、通过CTAS/CDAS语句同步数据及表结构变更
2、通过INSERT INTO语句插入或更新数据
3、通过INSERT OVERWRITE语句覆写数据
3.1、my_table_1 表是非分区表，覆写整张my_table表
3.2、my_table_1 表是分区表
3.3、my_table_1 表是分区表，动态覆写 my_table表中的分区
3.4、my_table_1 表是分区表，覆写整张 my_table_1 表
1、通过CTAS/CDAS语句同步数据及表结构变更
以 OSS 为例，DDL
CREATE CATALOG `my-catalog` WITH (
'type' = 'paimon',
'metastore' = 'filesystem',
'warehouse' = '<warehouse>',
'fs.oss.endpoint' = '<fs.oss.endpoint>',
'fs.oss.accessKeyId' = '<fs.oss.accessKeyId>',
'fs.oss.accessKeySecret' = '<fs.oss.accessKeySecret>'
);| 配置项 |