Spark Scala-如何拒绝来自Datarame的坏记录(格式错误)，并将这些被拒绝的记录保存到新文件中

import org.apache.spark.sql.{DataFrame, SparkSession}
import org.apache.spark.sql.functions._

val spark = SparkSession.builder().appName("RejectBadRecords").getOrCreate()
import spark.implicits._

val originalData = spark.read.format("csv").option("header", "true").load("原始数据文件路径")

def isBadRecord(record: DataFrame): Boolean = {
  // 根据记录的特定条件判断是否为坏记录
  // 返回true表示是坏记录，返回false表示不是坏记录
}

val badRecords = originalData.filter(isBadRecord)
val goodRecords = originalData.filter(!isBadRecord)

badRecords.write.format("csv").option("header", "true").save("坏记录文件路径")