如何使用U-SQL脚本添加两个csv文件的元素？

// 引用需要的命名空间
REFERENCE ASSEMBLY [Microsoft.Analytics.Samples.Formats];

// 定义输入文件路径和格式
DECLARE @input1 string = "/input/input1.csv";
DECLARE @input2 string = "/input/input2.csv";
DECLARE @output string = "/output/output.csv";

// 定义输入文件的结构
@input1_data =
    EXTRACT col1 int,
            col2 string
    FROM @input1
    USING new Microsoft.Analytics.Samples.Formats.Csv.CsvExtractor();

@input2_data =
    EXTRACT col3 int,
            col4 string
    FROM @input2
    USING new Microsoft.Analytics.Samples.Formats.Csv.CsvExtractor();

// 合并两个输入数据集
@result =
    SELECT col1,
           col2,
           col3,
           col4
    FROM @input1_data
    FULL OUTER JOIN @input2_data
        ON col1 == col3;

// 输出结果到CSV文件
OUTPUT @result
TO @output
USING Outputters.Csv();