2017-08-25 59 views
1

對於新手問題,我正在使用Databricks,並試圖在同一個Scala筆記本中將Scala的數據框傳遞給Python。我通過一個數據幀從使用Python星火:在Databricks中將變量從Scala傳遞到Python

%python 
python_df.registerTempTable("temp_table") 


val scalaDF = table("temp_table") 

我該怎麼做,在反向同樣的事情?非常感謝!!

回答

2

反過來將幾乎相同。在斯卡拉:

scalaDF.registerTempTable("some_table") 

在Python:

spark.table("some_table") 

如果您使用最新版本的Spark,你應該在的地方registerTempTable使用createOrReplaceTempView