我们可以使用 U-SQL 用户定义的运算符处理多行吗?

Can we process multiple rows using U-SQL User defined operators?

我正在尝试使用 this link 开发 U-SQL 用户定义的运算符。看起来我们可以读取一行,处理它并使用 UDO 将其作为一行写入。

在我的场景中,我必须读取多个连续行并写入多个连续行,使用博客中提供的帮助似乎不可能。

在另一种情况下,我必须处理单行并分成多行,然后写入输出。

我想知道是否可以使用 U-SQL UDO 处理多行,或者是否有任何其他方法可以在 U-SQL 中处理?

您可以编写自定义应用程序来获取单行和 return 多行。您使用 CROSS APPLY 调用它。

您可以编写自定义缩减器(或用户定义的聚合器)来获取多行(单元格)和 return 单行(单元格)。

你想通过阅读几行、查看所有行然后 return 几行来做什么?这是否类似于自连接(您可以使用组合器)?