更新时间:2024-11-29 GMT+08:00

ClickHouse输出

概述

“ClickHouse输出”算子,用于配置已生成的字段输出到ClickHouse表的列。

输入与输出

  • 输入:需要输出的字段
  • 输出:ClickHouse表

参数说明

表1 算子参数说明

参数

含义

类型

是否必填

默认值

数据库名

配置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表中数据: