擅长:python、mysql、java
<p>您可以使用where函数获得如下结果</p>
<pre><code>df.withColumn("result", when(($"num1" / $"num2") < 1, $"num2")
.otherwise($"num1"))
</code></pre>
<p>与其使用自定义项,不如使用可用函数。你知道吗</p>
<p>如果你还想使用自定义项,你可以注册你的自定义项以上作为</p>
<pre><code>calc_z = udf(calculate, FloatType())
</code></pre>
<p>希望这有帮助!你知道吗</p>