擅长:python、mysql、java
<p>你可以做:</p>
<pre><code>sp = None
def f(x):
sp = spark.createDataFrame(x)
return (sp)
sp = sp.union(rdd.foreach(f))
</code></pre>
<p>参考:</p>
<p><a href="https://spark.apache.org/docs/latest/api/python/pyspark.sql.html" rel="nofollow noreferrer">Spark SQL DataFrame</a></p>
<p><a href="https://www.tutorialspoint.com/pyspark/pyspark_rdd.htm" rel="nofollow noreferrer">Spark RDD</a></p>
<p>如果可行,请投票</p>