Pipeline 转换器
处理模式
| 处理模式 | 是否支持 |
|---|---|
| 批处理 | 不支持 |
| 流处理 | 不支持 |
| 同步流 | 支持 |
| 数据验证 | 不支持 |
配置
| 配置 | 描述 |
|---|---|
| Transforme | 配置转换规则 |
| Route | 配置路由规则 |
yaml
transform
:
-
description
:
append calculated columns
# 转换器描述
projection
:
id_2,title,authors
# 提取和转换的字段
source-table
:
flink.books
# 转换的源表名
yaml
route
:
-
description
:
test_t3
# 路由器描述
sink-table
:
flink.zjx_t3
# 路由目标表
source-table
:
flink.t3
# 路由源表