应该如何修改从网络驱动器读取5G日志文件的Scala脚本以读取最后的x行（如Unix中的“tail”）？

作者: biu~
发布时间: 2025-02-06 04:51:42 (24天前)
转自：

4 条回复

0#
回复此人
部落用户 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我在这个中使用了一个可变队列： </p> <pre> <code> ::#!@echo off call scala %0 %* goto :eof ::!# import scala.io.Source val lastN = 5 // I guess you'll be getting them from args, but... val queue = new scala.collection.mutable.Queue[String] if (args.length > 0) { Source.fromFile(args(0)).getLines foreach { line => queue.enqueue(line) if (queue.size > lastN) queue.dequeue } for (line <- queue) if (line.contains("percent")){ print(line) } } </code> </pre> <P> 如果使用不可变队列，我会使用reduceLeft，但我认为使用不可变队列没有意义。 </p> </DIV>

编辑
1#
回复此人
妖邪 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 如果读取文件是昂贵的，正如我所期望的那样是通过网络，我会寻找文件的末尾并逐步读取更大的块（更多关于日志文件格式的领域知识可能会给你一个更好的策略）结束，直到找到您要查找的行数。 </p> </DIV>

编辑
2#
回复此人
star*위위 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 你显然必须保留x行的缓冲区，你在每次迭代时都会更新： </p> <pre> <code> var buf: List[String] = Nil for (line <- ...) { buf = (buf ::: List(line)) match { case x :: xs if (xs.length == n) => xs } } </code> </pre> </DIV>

编辑

登录后才能参与评论