scala 如何在ADF流水线中从笔记本返回整数值

k2arahey  于 2022-11-09  发布在  Scala
关注(0)|答案(2)|浏览(112)

我有一个用例,其中我需要返回一个整数作为流水线中的Synapse笔记本的输出,并在流水线的下一阶段传递这个输出。
目前*mspark kutils.note book.exit()只接受字符串值。有没有什么实用的方法可以解决这个问题呢?我知道我们可以将整数转换为字符串类型,并将其发送到Exit(“”)*方法。我想知道我是否可以在没有选角的情况下做到这一点。

wfypjpf4

wfypjpf41#

cast()函数是Spark自己推荐的标准和官方方法。AFAIK,没有其他方法了。否则,您需要以编程方式管理它。
您还可以在动态内容中尝试@equals,以检查从笔记本活动输出中获取的exitValue是否等于某个特定值。

@equals(activity('Notebook').output.status.Output.result.exitValue, '<value>')

参考:Spark Cast StringType to Integer Type(整型),通过运行Synapse笔记本转换数据

vpfxa7rd

vpfxa7rd2#

相反,您可以在动态内容中将字符串数字转换为整数。如下所示:

@equals(
    int(activity('Notebook').output.status.Output.result.exitValue)
    ,1)

或者添加一个将字符串值设置为整型变量的活动。

相关问题