如何使用job spark测量hdfs上的读写时间？

import org.apache.spark.SparkConf
import org.apache.spark.SparkContext
import org.apache.hadoop.fs.{FileSystem, Path}

val conf = new SparkConf().setAppName("HDFSReadWriteTimeMeasurement")
val sc = new SparkContext(conf)

val filePath = "hdfs://<HDFS_MASTER>:<HDFS_PORT>/path/to/file"

def readHDFSFile(filePath: String): Unit = {
  val startTime = System.currentTimeMillis()
  val fileRDD = sc.textFile(filePath)
  fileRDD.count()  // 触发实际读取操作
  val endTime = System.currentTimeMillis()
  val readTime = endTime - startTime
  println(s"读取时间：$readTime 毫秒")
}

def writeHDFSFile(filePath: String): Unit = {
  val startTime = System.currentTimeMillis()
  val data = sc.parallelize(Seq("data1", "data2", "data3"))
  data.saveAsTextFile(filePath)
  val endTime = System.currentTimeMillis()
  val writeTime = endTime - startTime
  println(s"写入时间：$writeTime 毫秒")
}

readHDFSFile(filePath)
writeHDFSFile(filePath)