擅长:python、mysql、java
<p>请试试这个:</p>
<pre><code>import uuid
from pyspark.sql.functions import udf
uuidUdf= udf(lambda : str(uuid.uuid4()),StringType())
Df1 = Df.withColumn("id",uuidUdf())
</code></pre>
<p><strong>注意:</strong>您应该在添加新列之后分配给新的DF。(<em>Df1=Df.WITH列(…)</em></p>