hampel proposal 2

Review this independently proposed patch against the supplied starter. Use the lower weighted median: the smallest value whose cumulative weight reaches at least half the total. Trace the native model, algorithm services, repository snapshot and HTTP preview. Repair the incident while preserving the other contracts. All explicit fixtures and mandatory regression groups are available with bash test/run.sh.

Review focus: robust-statistics

src/services/weighted_median.py

BeforeProposed

+1−1

11from pyspark.sql import functions as F,Window

33def median(frame,column,output):

4 groups=frame.groupBy('anchor',F.col(column).alias('_value')).agg(F.count('*').alias('_weight'))

4 groups=frame.groupBy('anchor',F.col(column).alias('_value')).agg(F.sum('weight').alias('_weight'))

55 running=Window.partitionBy('anchor').orderBy('_value').rowsBetween(Window.unboundedPreceding,Window.currentRow)

66 total=Window.partitionBy('anchor')

77 ranked=groups.withColumn('_total',F.sum('_weight').over(total)).withColumn('_running',F.sum('_weight').over(running))

Your review

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

30 more characters to give a verdict