跳到主要内容
版本:Next

定义写入字段类型

DefineSinkType:为 sink 建表或写入阶段显式指定字段类型

描述

DefineSinkType 转换插件用于定义 sink 字段的目标存储类型,适用于开启 savemode 自动建表的场景。

参数

参数名类型是否必填默认值说明
columnslist<map<string, string>>需要定义的列,必须为每一列指定名称和类型

示例

指定部分字段的建表类型

transform {
DefineSinkType {
columns = [
{
column = "c1"
type = "nvarchar2(10)"
}
{
column = "c2"
type = "datetime(6)"
}
{
column = "c3"
type = "your target type"
}
]
}
}