src/services/windows.py
BeforeProposed
+1−1
33def windows(frame,width):
44 left=frame.alias('a')
55 right=frame.alias('s')
6 condition=(F.col('a.group')==F.col('s.group')) & (F.col('s.time')>F.col('a.time')-width) & (F.col('s.time')<=F.col('a.time'))
6 condition=(F.col('a.group')==F.col('s.group')) & (F.col('s.time')>=F.col('a.time')-width) & (F.col('s.time')<=F.col('a.time'))
77 return left.join(right,condition).select(F.col('a.id').alias('anchor'),F.col('s.value').alias('value'),F.col('s.weight').alias('weight'))