我正在使用 Databricks 并尝试在同一个 Scala 笔记本中将数据帧从 Scala 传递到 Python。我使用以下方法将数据帧从 Python 传递到 Spark:
%python
python_df.registerTempTable("temp_table")
val scalaDF = table("temp_table")
我如何反向做同样的事情?太感谢了!!
反之亦然。在斯卡拉中:
scalaDF.registerTempTable("some_table")
在Python中:
spark.table("some_table")
如果您使用最新的 Spark 版本,您应该使用createOrReplaceTempView
代替registerTempTable
.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)