Paimon中如何创建tables?

提问者:帅平 问题分类:大数据
Paimon中如何创建tables?
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']
);
发布于:9个月前 (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']
);
发布于:9个月前 (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'
);
发布于:9个月前 (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'
);
发布于:9个月前 (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);
发布于:9个月前 (09-06) IP属地:四川省
我来回答