擅长:python、mysql、java
<p>你可以这样接近</p>
<pre><code>import pyspark.sql.functions as F
exprs = [F.when(F.array_contains(F.col('list_column'), column), 1).otherwise(0).alias(column)\
for column in list_column_names]
df = df.select(['list_column']+exprs)
</code></pre>