K
Переслано от KrivdaTheTriewe
import zio._
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(_)))
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(_)))