并行进行表计算并合并结果到一张表

如何并行计算的几张内存表,最后将计算结果合并在一张表内。

目前希望如果计算中某些表无法计算,则希望返回空值,然后通过 dropna 删除,请问应该怎么写脚本?

伪代码如下:

attachments-2023-04-ie9LuZxV644b791fc54e9.png

请先 登录 后评论

1 个回答

veryOrdinary

可以参考下述代码进行改写:

def work(p){
        if(p == 1)
                return table(1 2 3 as id)
        else
                return NULL
}
loop(work, 1 2 1).unionAll(false)

loop 返回一个子任务结果组成的元组,通过 unionAll 可以合并所有表的结果。

请先 登录 后评论