decomprimi e leggi il file gzip in scala

Question

In Scala, come si può decomprimere il testo contenuto in file.gz in modo che possa essere elaborato? Sarei felice di avere il contenuto del file memorizzato in una variabile o di salvarlo come file locale in modo che possa essere letto dal programma dopo.

In particolare, sto utilizzando Scalding per elaborare dati di registro compressi, ma Scalding non definisce un modo per leggerli in FileSource.scala.

Answer 1

Ecco la mia versione:

import java.io.BufferedReader 
import java.io.InputStreamReader 
import java.util.zip.GZIPInputStream 
import java.io.FileInputStream 

class BufferedReaderIterator(reader: BufferedReader) extends Iterator[String] { 
    override def hasNext() = reader.ready 
    override def next() = reader.readLine() 
} 

object GzFileIterator { 
    def apply(file: java.io.File, encoding: String) = { 
    new BufferedReaderIterator(
     new BufferedReader(
     new InputStreamReader(
      new GZIPInputStream(
      new FileInputStream(file)), encoding))) 
    } 
} 

Poi fare:

val iterator = GzFileIterator(new java.io.File("test.txt.gz"), "UTF-8") 
iterator.foreach(println)