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