一、创建数据库
create database iceberg_db;
use iceberg_db;
二、创建表
create table `hive_catalog`.`default`.`sample`(
id bigint comment 'unique id',
data string
);
建表命令支持最常用的flink建表语法，包括：文章来源地址https://www.toymoban.com/news/detail-513219.html
- PARTITION BY(column1,column2,…)：配置分区，apache flink不支持隐藏分区。
- COMMENT ‘table document’：指定表的备注
- WITH(‘key’=‘value’,…)：设置表属性
desc sample
三、创建分区表
create table sample1(id bigint,data string) partitioned by(data);
desc sample1;
四、使用LIKE语法建表
create table sample_like sample;
desc sample_like;
五、创建主键表
create table sample4(id bigint,data string,primary key (id) not enforce)
文章来源：https://www.toymoban.com/news/detail-513219.html
到了这里，关于Iceberg从入门到精通系列之八：flink sql 创建Iceberg表的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
