pyspark.pandas.broadcast

pyspark.pandas。 廣播 ( obj:pyspark.pandas.frame.DataFrame )→pyspark.pandas.frame.DataFrame

標誌著DataFrame作為使用廣播加入足夠小。

使用DataFrame.spark.hint ()代替。

參數
obj DataFrame
返回
受潮濕腐爛 DataFrame與廣播提示。

另請參閱

DataFrame.merge

合並DataFrame對象數據庫樣式加入。

DataFrame.join

另一個DataFrame的連接列。

DataFrame.update

從另一個DataFrame使用non-NA值修改到位。

DataFrame.hint

指定當前DataFrame一些提示。

例子

> > >df1=psDataFrame({“lkey”:(“foo”,“酒吧”,“記者”,“foo”),“價值”:(1,2,3,5)},=(“lkey”,“價值”])set_index(“lkey”)> > >df2=psDataFrame({“rkey”:(“foo”,“酒吧”,“記者”,“foo”),“價值”:(5,6,7,8)},=(“rkey”,“價值”])set_index(“rkey”)> > >合並後的=df1合並(ps廣播(df2),left_index=真正的,right_index=真正的)> > >合並後的火花解釋()= = = =物理計劃BroadcastHashJoin…