擅长:python、mysql、java
<p>您可以使用<code>Window</code>来执行此操作</p>
<p>即</p>
<pre><code>import pyspark.sql.functions as F
from pyspark.sql.window import Window
window_var = Window().partitionBy('Categroy')
df = df.withColumn('DemeanedValues', F.col('Values') - F.mean('Values').over(window_var))
</code></pre>