擅长:python、mysql、java
<p>谢谢你,塞利姆。这似乎也可行,但你的方法更清晰。你知道吗</p>
<pre><code>def string_replacement(string1, string2):
string2=string2.replace('Computer', 'Computer x')
string2=string2.replace('Science', 'Science x')
return string1, string2
output_schema = StructType([StructField('id', StringType(), True), StructField('name', StringType(), True)])
new_udf=f.udf(string_replacement, output_schema)
cols=df.columns
df.select( new_udf(f.col('id'), f.col('name')).alias('results')).select(f.col('results.*')).show(truncate = False)
</code></pre>