Sink 常用选项

Sink 连接器常用参数

名称	类型	是否需要	默认值
source_table_name	string	否	-
parallelism	int	否	-

source_table_name [string]

当不指定 source_table_name 时，当前插件处理配置文件中上一个插件输出的数据集 dataset

当指定了 source_table_name 时，当前插件正在处理该参数对应的数据集

parallelism [int]

当没有指定parallelism时，默认使用 env 中的 parallelism。

当指定 parallelism 时，它将覆盖 env 中的 parallelism。

Examples

source {
    FakeSourceStream {
      parallelism = 2
      result_table_name = "fake"
      field_name = "name,age"
    }
}

transform {
    Filter {
      source_table_name = "fake"
      fields = [name]
      result_table_name = "fake_name"
    }
    Filter {
      source_table_name = "fake"
      fields = [age]
      result_table_name = "fake_age"
    }
}

sink {
    Console {
      source_table_name = "fake_name"
    }
    Console {
      source_table_name = "fake_age"
    }
}

如果作业只有一个 source 和一个（或零个）transform 和一个 sink ，则不需要为连接器指定 source_table_name 和 result_table_name。 如果 source 、transform 和 sink 中任意运算符的数量大于 1，则必须为作业中的每个连接器指定 source_table_name 和 result_table_name