在Databricks中将变量从Scala传递到Python
问题描述:
对于新手问题,我正在使用Databricks,并试图在同一个Scala笔记本中将Scala的数据框传递给Python。我通过一个数据帧从使用Python星火:在Databricks中将变量从Scala传递到Python
%python
python_df.registerTempTable("temp_table")
val scalaDF = table("temp_table")
我该怎么做,在反向同样的事情?非常感谢!!
答
反过来将几乎相同。在斯卡拉:
scalaDF.registerTempTable("some_table")
在Python:
spark.table("some_table")
如果您使用最新版本的Spark,你应该在的地方registerTempTable
使用createOrReplaceTempView
。