我們可以使用U-SQL用戶定義的運算符來處理多行嗎？

Question

我正在嘗試使用this鏈接開發U-SQL用戶定義的運算符。看起來我們可以讀取一行，使用UDO對其進行處理並將其寫入單行。

在我的場景中，我必須讀取多個連續的行並寫入多個連續的行，並且這似乎不可能使用博客中提供的幫助。

在另一種情況下，我必須處理單行並分解爲多個，然後寫入輸出。

我想知道是否有可能使用U-SQL UDO處理多行或者如果在U-SQL中有任何其他方式來處理它？

Answer 1

您可以編寫一個自定義應用程序來獲取單行並返回多行。你用CROSS APPLY調用它。

您可以編寫自定義縮減器（或用戶定義的聚合器）以獲取多行（單元格）並返回單個行（單元格）。

你想通過閱讀幾行，看到他們，然後返回幾行？這會類似於一個自我加入（你可以使用一個組合器）？