3

scalaz-stream次のコードを高速化するにはどうすればよいですか? 現在、70MB のテキストを処理するのに約 5 分かかります。単純な scala と同等の処理には数秒かかるため、おそらくかなり間違ったことをしているのでしょう。

(別の質問へのフォローアップ)

  val converter2: Task[Unit] = {
    val docSep = "~~~"
    io.linesR("myInput.txt")
      .flatMap(line => { val words = line.split(" ");
          if (words.length==0 || words(0)!=docSep) Process(line)
          else Process(docSep, words.tail.mkString(" ")) })
      .split(_ == docSep)
      .filter(_ != Vector())
      .map(lines => lines.head + ": " + lines.tail.mkString(" "))
      .intersperse("\n")
      .pipe(text.utf8Encode)
      .to(io.fileChunkW("correctButSlowOutput.txt"))
      .run
  }
4

2 に答える 2