如何使用Scala解压snappy (hadoop文件格式)文件

import org.xerial.snappy.SnappyInputStream
import java.io.{FileInputStream, FileOutputStream}

def decompressSnappyFile(inputFilePath: String, outputFilePath: String): Unit = {
  val inputFile = new FileInputStream(inputFilePath)
  val outputFile = new FileOutputStream(outputFilePath)
  val snappyInputStream = new SnappyInputStream(inputFile)

  val buffer = new Array[Byte](1024)
  var bytesRead = snappyInputStream.read(buffer)
  while (bytesRead > 0) {
    outputFile.write(buffer, 0, bytesRead)
    bytesRead = snappyInputStream.read(buffer)
  }

  snappyInputStream.close()
  outputFile.close()
}

val inputFilePath = "/path/to/input.snappy"
val outputFilePath = "/path/to/output.txt"

decompressSnappyFile(inputFilePath, outputFilePath)