如何在 U-SQL 中抛出错误或引发异常？

Question

在 U-Sql 脚本中引发错误或异常的机制是什么？我有一个场景，正在处理一个CSV文件，如果在里面发现重复，那么我需要放弃处理。

在 SQL 中，我可以做 raiseerror，这与在 U-Sql 中的等效方法是什么？

Answer 1

创建一个 c# 函数来引发自定义错误（或输出到文件）：

DECLARE @RaiseError Func<string, int> = (error) => 
    {
        throw new Exception(error);
        return 0;
    };

@Query = 
    SELECT @RaiseError(value) AS ErrorCode
    FROM (VALUES ("my custom error description")) AS T(value);

OUTPUT @Query TO "/Output/errors.txt" USING Outputters.Csv(quoting : true);

如何在 U-SQL 中抛出错误或引发异常？

How to throw a error or raise exception in U-SQL?

azure-data-lake

u-sql