如何并行计算的几张内存表,最后将计算结果合并在一张表内。
目前希望如果计算中某些表无法计算,则希望返回空值,然后通过 dropna 删除,请问应该怎么写脚本?
伪代码如下:
可以参考下述代码进行改写:
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 可以合并所有表的结果。