src/services/visibility.py
BeforeProposed
+2−2
22
33
44def latest(frame, as_of):
5 visible = frame
5 visible = frame.filter(F.col('observed') <= as_of)
66 window = Window.partitionBy('id').orderBy(F.col('observed').desc())
7 return visible.withColumn('_rank', F.row_number().over(window)).filter('_rank = 1').filter(F.col('observed') <= as_of).drop('_rank')
7 return visible.withColumn('_rank', F.row_number().over(window)).filter('_rank = 1').drop('_rank')