如何在PySpark中跨多个时间间隔使用.filter()操作？

from pyspark.sql import SparkSession
from pyspark.sql.functions import col
from datetime import datetime, timedelta

# 创建SparkSession
spark = SparkSession.builder.getOrCreate()

# 创建示例数据
data = [
    ("2022-01-01", "A"),
    ("2022-01-02", "B"),
    ("2022-01-03", "C"),
    ("2022-01-04", "D"),
    ("2022-01-05", "E"),
    ("2022-01-06", "F")
]
df = spark.createDataFrame(data, ["date", "value"])

# 定义时间间隔
start_date = datetime.strptime("2022-01-02", "%Y-%m-%d")
end_date = datetime.strptime("2022-01-04", "%Y-%m-%d")

# 使用.filter()操作跨多个时间间隔筛选数据
filtered_df = df.filter((col("date") >= start_date) & (col("date") <= end_date))

# 显示筛选后的结果
filtered_df.show()