解压缩并读取scala中的gzip文件

Question

在Scala中，如何解压缩包含在file.gz中的文本以便它可以被处理？我会很高兴将文件的内容存储在一个变量中，或者将其保存为本地文件，以便后面的程序可以读取它。

具体来说，我使用Scalding来处理压缩的日志数据，但Scalding没有定义在FileSource.scala中读取它们的方法。

Answer 1

这里是我的版本：

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))) 
    } 
} 

然后做：

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