如何编写组件“将数据写入HDFS目录”的Scala测试

import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.fs.{FileSystem, Path}
import org.scalatest.{BeforeAndAfterAll, FlatSpec, Matchers}

class WriteToHDFSTest extends FlatSpec with Matchers with BeforeAndAfterAll {
  // 测试代码
}

override def beforeAll(): Unit = {
  // 初始化测试环境
}

override def afterAll(): Unit = {
  // 清理测试环境
}

it should "write data to HDFS directory" in {
  // 准备测试数据
  val data = "Hello, HDFS!"
  val outputPath = "/path/to/output"

  // 创建Hadoop配置对象
  val conf = new Configuration()
  conf.set("fs.defaultFS", "hdfs://localhost:9000")

  // 创建Hadoop文件系统对象
  val fs = FileSystem.get(conf)

  // 创建输出路径
  val outputDir = new Path(outputPath)
  fs.mkdirs(outputDir)

  // 将数据写入HDFS目录
  val outputFilePath = new Path(outputPath + "/data.txt")
  val outputStream = fs.create(outputFilePath)
  outputStream.write(data.getBytes("UTF-8"))
  outputStream.close()

  // 验证数据是否成功写入
  val inputFilePath = new Path(outputPath + "/data.txt")
  val inputStream = fs.open(inputFilePath)
  val actualData = scala.io.Source.fromInputStream(inputStream).mkString
  inputStream.close()

  actualData should be(data)
}