Как скрипт Scala, который считывает файл журнала 5G с сетевого диска, должен быть изменен, чтобы читать последние строки x (например, «хвост» в Unix)?

Question

Как скрипт Scala, который считывает файл журнала 5G с сетевого диска, должен быть изменен, чтобы читать последние строки x (например, «хвост» в Unix)?

::#! 
@echo off 
call scala %0 %* 
goto :eof 
::!# 

import scala.io.Source 
if (args.length > 0) { 
for (line <-Source.fromFile(args(0)).getLines) 
if(line.contains("percent")){ 
    print(line) 
} 
} 

Answer 1

Я использую изменяемый очереди в этой:

::#!@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) 
    } 
} 

Если вы используете неизменяемую очередь, я бы использовал reduceLeft, но я не вижу смысла использовать для этого неизменяемую очередь.

Answer 2

Вы, очевидно, придется держать буфер х линий, которые вы обновляете на каждой итерации:

var buf: List[String] = Nil 

for (line <- ...) { 
    buf = (buf ::: List(line)) match { 
    case x :: xs if (xs.length == n) => xs 
    } 
} 

Answer 3

Если чтение файла стоит дорого, так как я ожидаю, что это по сети, я бы поискал до конца файла и читал постепенно более крупные фрагменты (больше знаний о домене в формате файла журнала может дать вам лучшую стратегию здесь) с конца, пока не найдете количество строк, которые вы ищете.