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 # 路由源表