如何在pyspark中指定以毫秒为单位的窗口大小？

from pyspark.sql import SparkSession
from pyspark.sql.functions import window, expr

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

# 读取数据流
df = spark.readStream.format("kafka").option("kafka.bootstrap.servers", "localhost:9092").load()

# 指定以毫秒为单位的窗口大小
windowed_df = df.selectExpr("timestamp", "value") \
    .withColumn("window", window("timestamp", expr("10 seconds")))  # 窗口大小为10秒

# 对窗口数据进行聚合操作
aggregated_df = windowed_df.groupBy("window").agg({"value": "sum"})

# 输出结果
query = aggregated_df.writeStream.outputMode("complete").format("console").start()

# 启动数据流查询
query.awaitTermination()