如何在PySpark中删除某个条件之前的所有行？
第一个
我想到的条件是，删除所有Time小于LatestRecord == 1的行，但我很难做到这一点。
到目前为止我的（失败的）尝试：

# transform min date; fails
df = df.withColumn('earliestDate', F.when( F.col('LatestRecord') == 1, F.col('Time').over(Window.partitionBy('ID'))))

# then when earliestDate >= Time, filter
df = df.filter(df.earliestDate >= df.Time)