Skip to content

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