全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言机器学习

Paimon中如何创建tables？

提问者：帅平问题分类：大数据

Paimon中如何创建tables？

Paimon

发布于：11个月前 (09-06) IP属地：四川省

5 个回答

本姑娘贼稳妥

使用Presto创建table的话，示例sql如下：

CREATE TABLE MyTable (
    user_id BIGINT,
    item_id BIGINT,
    behavior VARCHAR,
    dt VARCHAR,
    hh VARCHAR
) WITH (
    primary_key = ARRAY['dt', 'hh', 'user_id'],
    partitioned_by = ARRAY['dt', 'hh']
);

发布于：11个月前 (09-06) IP属地：四川省

巴黎小甜心

使用Trino创建table的话，示例slq如下：

CREATE TABLE MyTable (
    user_id BIGINT,
    item_id BIGINT,
    behavior VARCHAR,
    dt VARCHAR,
    hh VARCHAR
) WITH (
    primary_key = ARRAY['dt', 'hh', 'user_id'],
    partitioned_by = ARRAY['dt', 'hh']
);

发布于：11个月前 (09-06) IP属地：四川省

爱你的小笨蛋

使用hive创建table的话，示例sql如下：

SET hive.metastore.warehouse.dir=warehouse_path;
CREATE TABLE MyTable (
    user_id BIGINT,
    item_id BIGINT,
    behavior STRING
) PARTITIONED BY ( 
    dt STRING,
    hh STRING
)
STORED BY 'org.apache.paimon.hive.PaimonStorageHandler'
TBLPROPERTIES (
    'primary-key' = 'dt,hh,user_id'
);

发布于：11个月前 (09-06) IP属地：四川省

`小囡

使用spark3创建table的话，示例sql如下：

CREATE TABLE MyTable (
    user_id BIGINT,
    item_id BIGINT,
    behavior STRING,
    dt STRING,
    hh STRING
) PARTITIONED BY (dt, hh) TBLPROPERTIES (
    'primary-key' = 'dt,hh,user_id'
);

发布于：11个月前 (09-06) IP属地：四川省

激萌美少女

使用flink创建table的话，示例sql如下：

CREATE TABLE MyTable (
    user_id BIGINT,
    item_id BIGINT,
    behavior STRING,
    dt STRING,
    hh STRING,
    PRIMARY KEY (dt, hh, user_id) NOT ENFORCED
) PARTITIONED BY (dt, hh);

发布于：11个月前 (09-06) IP属地：四川省

我来回答