使用pyspark如何拒绝csv文件中的坏(格式错误)记录，并将这些被拒绝的记录保存到新文件中

from pyspark.sql import SparkSession
from pyspark.sql.functions import col

spark = SparkSession.builder.appName("BadRecords").getOrCreate()

df = spark.read.csv("input.csv", header=True, inferSchema=True)

def is_bad_record(row):
    # 在这里编写检查坏记录的逻辑
    # 如果记录是坏记录，返回True；否则返回False
    pass

bad_records = df.filter(is_bad_record(col("*")))

bad_records.write.csv("bad_records.csv", header=True)

from pyspark.sql import SparkSession
from pyspark.sql.functions import col

def is_bad_record(row):
    # 在这里编写检查坏记录的逻辑
    # 如果记录是坏记录，返回True；否则返回False
    pass

spark = SparkSession.builder.appName("BadRecords").getOrCreate()

df = spark.read.csv("input.csv", header=True, inferSchema=True)

bad_records = df.filter(is_bad_record(col("*")))

bad_records.write.csv("bad_records.csv", header=True)