相关疑难解决方法(0)

使用Akka Streams读取CSV文件

我正在读一个csv文件.我正在使用Akka Streams执行此操作,以便我可以创建要在每一行执行的操作的图表.我已经启动并运行了以下玩具示例.

  def main(args: Array[String]): Unit = {
    implicit val system = ActorSystem("MyAkkaSystem")
    implicit val materializer = ActorMaterializer()

        val source = akka.stream.scaladsl.Source.fromIterator(Source.fromFile("a.csv").getLines)
        val sink = Sink.foreach(println)
        source.runWith(sink)
      }
Run Code Online (Sandbox Code Playgroud)

这两种Source类型对我来说并不容易.这是惯用的还是有更好的方法来写这个?

scala akka akka-stream

11
推荐指数
4
解决办法
8827
查看次数

标签 统计

akka ×1

akka-stream ×1

scala ×1