pyspark.pandas.broadcast¶
-
pyspark.pandas。廣播( obj:pyspark.pandas.frame.DataFrame )→pyspark.pandas.frame.DataFrame¶ -
標誌著DataFrame作為使用廣播加入足夠小。
- 參數
-
- obj DataFrame
- 返回
-
- 受潮濕腐爛 DataFrame與廣播提示。
另請參閱
-
DataFrame.merge -
合並DataFrame對象數據庫樣式加入。
-
DataFrame.join -
另一個DataFrame的連接列。
-
DataFrame.update -
從另一個DataFrame使用non-NA值修改到位。
-
DataFrame.hint -
指定當前DataFrame一些提示。
例子
> > >df1=ps。DataFrame({“lkey”:(“foo”,“酒吧”,“記者”,“foo”),…“價值”:(1,2,3,5)},…列=(“lkey”,“價值”])。set_index(“lkey”)> > >df2=ps。DataFrame({“rkey”:(“foo”,“酒吧”,“記者”,“foo”),…“價值”:(5,6,7,8)},…列=(“rkey”,“價值”])。set_index(“rkey”)> > >合並後的=df1。合並(ps。廣播(df2),left_index=真正的,right_index=真正的)> > >合並後的。火花。解釋()= = = =物理計劃…BroadcastHashJoin……