如果你不使用合并，你可以尝试Windows：

from pyspark.sql import SparkSession
from pyspark.sql.functions import max as spark_max, min as spark_min
from pyspark.sql.window import Window

spark = SparkSession.builder.getOrCreate()

window = Window.partitionBy('Race_Event_ID')

df = df.withColumn('Max_Speed', spark_max('Speed').over(window))
df = df.withColumn('Min_Speed', spark_min('Speed').over(window))

topper = df.filter(df['Speed'] == df['Max_Speed'])
tailer = df.filter(df['Speed'] == df['Min_Speed'])

topper_info = topper.select('Race_Event_ID', 'Car_ID', 'Driver_ID', 'Speed')
tailer_info = tailer.select('Race_Event_ID', 'Car_ID', 'Driver_ID', 'Speed')