跳到主要内容
版本:2.3.8

行类型过滤

行类型转换插件

描述

按行类型过滤数据

操作

名称类型是否必须默认值
include_kindsarrayyes
exclude_kindsarrayyes

include_kinds [array]

要包含的行类型

exclude_kinds [array]

要排除的行类型。

您只能配置 include_kindsexclude_kinds 中的一个。

common options [string]

转换插件的常见参数, 请参考 Transform Plugin 了解详情

示例

FakeSource 生成的数据的行类型是 INSERT。如果我们使用 FilterRowKink 转换并排除 INSERT 数据,我们将不会向接收器写入任何行。


env {
job.mode = "BATCH"
}

source {
FakeSource {
result_table_name = "fake"
row.num = 100
schema = {
fields {
id = "int"
name = "string"
age = "int"
}
}
}
}

transform {
FilterRowKind {
source_table_name = "fake"
result_table_name = "fake1"
exclude_kinds = ["INSERT"]
}
}

sink {
Console {
source_table_name = "fake1"
}
}