ClickHouse输出
概述
“ClickHouse输出”算子,用于配置已生成的字段输出到ClickHouse表的列。
输入与输出
- 输入:需要输出的字段。
- 输出:ClickHouse表。
参数说明
参数 |
含义 |
类型 |
是否必填 |
默认值 |
---|---|---|---|---|
数据库名 |
配置ClickHouse表所在的数据库。 |
string |
是 |
default |
表名 |
配置数据写入ClickHouse对应的表名。 |
string |
是 |
无 |
数据处理规则
将字段值输出到ClickHouse表中。
样例
通过“CSV文件输入”算子,生成十二个字段。
源文件如下:
创建ClickHouse表的语句如下:
CREATE TABLE IF NOT EXISTS testck4 ON CLUSTER default_cluster(
a Int32,
b VARCHAR(100) NOT NULL,
c char(100),
d DateTime,
e DateTime,
f DateTime,
g smallint,
h bigint,
l Float32,
j Float64,
k decimal(10,2),
m boolean
)
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/default/testck4', '{replica}')
PARTITION BY toYYYYMM(d)ORDER BY a;
配置“ClickHouse输出”算子,如下图:
作业执行成功后,查看testck4表中数据: