U-SQL：如何向用户定义的Reducer传递参数？

在U-SQL中，可以使用脚本定义用户自定义的Reducer，并向其传递参数。下面是一个示例：

首先，定义一个用户自定义的Reducer脚本文件，例如"CustomReducer.usql"：

// 定义自定义Reducer
// 参数可以在脚本中使用
DECLARE @myParameter string = "";

// 定义Reducer函数
@customReducer = REDUCE @input
                ON (key)
                USING new Extension.CustomReducer(@myParameter);

// 自定义Reducer的实现
public class CustomReducer : IReducer
{
    private string _parameter;

    public CustomReducer(string parameter)
    {
        this._parameter = parameter;
    }

    public override Schema GetOutputSchema()
    {
        // 返回自定义Reducer的输出模式
        return new Schema(...);
    }

    public override void Reduce(IRowset input, IRowset output, IUpdatableRow outputRow)
    {
        // 自定义Reducer的逻辑
        // 使用参数 _parameter
        ...
    }
}

然后，在主脚本中调用自定义的Reducer，并传递参数：

DECLARE @inputTable TABLE (key string, ...);

@result = SELECT ...
          FROM @inputTable
          REDUCE BY key
          USING new Extension.CustomReducer(@myParameter = "value");

OUTPUT @result TO "/output/result.csv"
USING Outputters.Csv();

在这个示例中，我们使用自定义的Reducer来处理输入表@inputTable，并传递了一个参数@myParameter。在自定义Reducer的脚本中，我们声明了一个与传递的参数相对应的变量，并在Reducer函数的构造函数中使用它。

请注意，在使用自定义Reducer之前，需要先将其打包为扩展。有关如何创建和使用扩展的更多信息，请参考U-SQL扩展的相关文档。