在Databricks中将变量从Scala传递到Python
问题描述
我正在使用Databricks,并试图在同一个Scala笔记本中将一个数据帧从Scala传递到Python。我使用以下命令将数据帧从Python传递给Spark:
%python
python_df.registerTempTable("temp_table")
val scalaDF = table("temp_table")
如何反向执行相同的操作?非常感谢!!
解决方案
反之亦然。在Scala中:
scalaDF.registerTempTable("some_table")
在Python中:
spark.table("some_table")
如果使用最新版本的Spark,则应使用createOrReplaceTempView
代替registerTempTable
。
相关文章