在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

相关文章