00:00:00

survival proposal 1

Review the independently proposed patch below, including its unchanged callers. Include subjects failing or censoring at a time in that time risk set. Process tied failures before removing censors. The complete application includes native models, services, repository projections, a working preview and visible acceptance cases. Preserve the other documented invariants and run bash test/run.sh.

Review focus: survival-analysis

src/services/risk.py

BeforeProposed

+1−1

11from pyspark.sql import functions as F

33def risk(frame,times):

4 condition=(F.col('s.group')==F.col('t.group')) & (F.col('s.entry')<=F.col('t.time')) & (F.col('s.time')>F.col('t.time'))

4 condition=(F.col('s.group')==F.col('t.group')) & (F.col('s.entry')<=F.col('t.time')) & (F.col('s.time')>=F.col('t.time'))

55 return times.alias('t').join(frame.alias('s'),condition).groupBy(F.col('t.group').alias('group'),F.col('t.time').alias('time')).agg(F.count('*').alias('risk'))

Your review

0 / 10,000 characters · A verdict needs supporting evidence.

30 more characters to give a verdict