减压.Z 文件存储在 Azure ADLS Gen2 中

Question

我有一个.Z文件存储在 Azure ADLS Gen2 中。我想解压缩 ADLS 中的文件，我尝试使用 ADF 和 C# 解压缩，但发现.不支持 Z。我也尝试使用Apache Common Compress Lib进行解压缩，但无法读取InputStream中的文件。

任何人都可以知道，我们如何在 Scala 中使用 Apache lib 解压缩文件。

Answer 1

.Z文件.gzip文件，所以你可以试试这种方法

import java.io.{BufferedReader, File, FileInputStream, InputStreamReader}
import java.util.zip.GZIPInputStream
object UnzipFiles {
def decompressGzipOrZFiles(file: File, encode: String): BufferedReader = {
val fis = new FileInputStream(file)
val gzis = new GZIPInputStream(fis)
val isr = new InputStreamReader(gzis, encode)
new BufferedReader(isr)
}
def main(args: Array[String]): Unit = {
val path = new File("/home/cloudera/files/my_file.Z")
// print to the console
decompressGzipOrZFiles(path,"UTF-8").lines().toArray.foreach(println)
}
}

或者你也可以遵循这个

def uncompressGzip(myFileDotZorGzip: String): Unit = {
import java.io.FileInputStream
import java.util.zip.GZIPInputStream
try {
val gzipInputStream = new GZIPInputStream(new FileInputStream(myFileDotZorGzip))
try {
val tam = 128
val buffer = new Array[Byte](tam)
do {
gzipInputStream.read(buffer)
gzipInputStream.skip(tam)
//do something with data
print(buffer.foreach(b => print(b.toChar)))
} while(gzipInputStream.read() != -1)
} finally {
if (gzipInputStream != null) gzipInputStream.close()
}
}
}

我希望这有所帮助。