内側混乱するIは、内側使用pyspark

Question

に参加このようpysparkシェルに参加：私は内部結合のために同じテーブルを使用

tab_df=ori_df.join(ori_df,ori_df.columns,'inner') 

ので、tab_df.count()はori_df.count()として等しくなければならないことが予想されるべきであるが、 tab_df.count()私に0を与える！

Answer 1

使用このコマンド：

tab_df = ori_df.join(ori_df, ['column_name']) 

pysparkは内部使用しています私は2つの同じテーブルを結合するために私のコンピュータにしようと、あなたが同じ2つに参加したいんなぜそれが

を作品デフォルト

で参加とにかくテーブル？