r - 在 U-SQL 中执行 R

Question

我正在尝试使用 U-SQL 和 R 进行预测，因此我需要从 U-SQL 向 R 传递一个值列表，并将预测从 R 返回到 U-SQL

我发现的所有示例都使用了 reducer，因此只会处理 1 行。

https://learn.microsoft.com/en-us/azure/data-lake-analytics/data-lake-analytics-u-sql-r-extensions

是否可以不向 R 发送列列表，而是发送行列表进行处理？

谢谢!

Answer 1

通过 definition用户定义的缩减器获取 n 行并生成一行或多行，使用它来生成新的列数据以及新的行。 U-SQL 的 R 扩展包括一个内置的缩减器 (Extension.R.Reducer)，它在分配给缩减器的每个顶点上运行 R 代码。您可以使用“inputFromUSQL”的特殊 R 参数获取输入行集，并使用 R 对其进行处理。

就像您提到的那样，这应该同时适用于所有行:

DECLARE @myRScript = @"
inputFromUSQL$mydata = as.factor(inputFromUSQL$mydata)
<..>
";

@myData = <my u-sql query>

@RScriptOutput = REDUCE @myData <..>
USING new Extension.R.Reducer(command:@myRScript, rReturnType:"dataframe")