在 ADF 数据流中,我们可以使用“衍生列”转换来添加多个连接符。以下示例将演示如何在数据流中添加多个连接符。
假设我们有以下输入数据:
name age city
John 25 New York
Mary 30 Los Angeles
Kevin 27 Chicago
我们想要将输入数据的列值连接成一个字符串,例如:
John|25|New York
Mary|30|Los Angeles
Kevin|27|Chicago
为了实现这个目标,我们可以使用以下步骤:
在数据流中添加“衍生列”转换。
在“衍生列”转换中为每个连接符添加一个新列。例如,我们想要使用竖杠“|”作为连接符,因此需要添加两个新列,分别为“|”和“||”。
使用“合并列”转换将所有列值合并为一个新列。在“合并列”转换中,将每个连接符列添加至“连接符”字段中,并将所有输入列添加至“输入列”字段中。
以下是示例代码,在其中我们假定“连接符”列为“|”和“||”:
source(output(
name as string,
age as integer,
city as string
))
transformation(derive(
"|" as string,
"||" as string
))
transformation(mergeColumns(
output(
combined_column as string
),
delimiter: dynamic("@item().delimiter"),
inputs: dynamic("@{concat('"', item().name, '", "', item().age, '", "', item().city, '", "')}")
))
最终的输出结果将如下所示:
combined_column
John|25|New York
Mary|30|Los Angeles
Kevin|27|Chicago