5 个回答
修改表
ALTER TABLE T SET ('full-compaction.delta-commits' = '1');
发布于:4个月前 (12-20) IP属地:四川省
删除数据
DELETE FROM T WHERE dt >= '20230503';
发布于:4个月前 (12-20) IP属地:四川省
写入数据:
#直接写
INSERT INTO T VALUES (1, 10001, 'varchar00001', '20230501');
#查询写入
INSERT INTO word_count SELECT word, COUNT(*) as cnt FROM source_word GROUP BY word;
发布于:4个月前 (12-20) IP属地:四川省
创建带有分区的表
CREATE TABLE if not EXISTS T (
id BIGINT,
a INT,
b STRING,
dt STRING COMMENT 'timestamp string in format yyyyMMdd',
PRIMARY KEY (id, dt) NOT ENFORCED
) PARTITIONED BY (dt)
with
(
-- 'target-file-size' = '256 MB',
-- 'file.format' = 'parquet',
-- 'file.compression' = 'zstd',
-- 'file.compression.zstd-level' = '3',
-- 'write-only' = 'true',
-- 'bucket' = '-1',
-- 'dynamic-bucket.target-row-num' ='2000000',
-- 'dynamic-bucket.initial-buckets' = '1'
);
发布于:4个月前 (12-20) IP属地:四川省
创建catalog
CREATE CATALOG paimon
WITH
(
'type' = 'paimon',
'warehouse' = 'hdfs://192.168.1.249:9000/tmp/paimon'
);
USE CATALOG paimon;
或者使用如下:CREATE CATALOG paimon
WITH
(
'type' = 'paimon',
'warehouse' = 'file:///tmp/paimon'
);
USE CATALOG paimon;
发布于:4个月前 (12-20) IP属地:四川省
我来回答
您需要 登录 后回答此问题!