I think you can just use the 'concurrent' argument on mergeScan... mergeScan(accumulatorFn, init, 1). concurrent limits the number of ...
確定! 回上一頁