scala - 如何通过 akka/alpakka 流传输 parquet 文件目录

Question

我试图通过 akka/alpakka 流流式传输镶木地板文件的目录，问题是虽然我将目录设置为源，但它只流式传输一个文件。

任何建议将不胜感激这是我的最后一个实验：

 val reader: ParquetReader[GenericRecord] =  AvroParquetReader.builder[GenericRecord](filePath).withConf(conf).build()

  val source: Source[GenericRecord, NotUsed] = AvroParquetSource(reader)

  source 
    .ask[WorkerAck](10)(workerActor)
    .runWith(Sink.ignore)

标签： scalaakkaparquetakka-streamalpakka