K
import zio.blocking.Blocking
def execute(path:String) = blocking.effectBlocking {
spark.read.parquet(path)
}
val load = paths.map(x => execute(x))
ZIO.collectAllPar(load).map(x => x.reduce(_.union(_)))
Size: a a a
K
Oℕ
K
Oℕ
Oℕ
K
Oℕ
K
Oℕ
K
K
K
K
Oℕ
Oℕ
Oℕ
K
λ
Oℕ