pyspark.sql.DataFrame.intersectAll

DataFrame。 intersectAll ( 其他:pyspark.sql.dataframe.DataFrame )→pyspark.sql.dataframe.DataFrame

返回一個新的DataFrame包含在這行DataFrame和另一個DataFrame同時保留副本。

這相當於相交的所有在SQL。作為SQL標準,這個函數解決列的位置(而不是按名稱)。

例子

> > >df1=火花createDataFrame(((“一個”,1),(“一個”,1),(“b”,3),(“c”,4)),(“C1”,“C2”])> > >df2=火花createDataFrame(((“一個”,1),(“一個”,1),(“b”,3)),(“C1”,“C2”])
> > >df1intersectAll(df2)排序(“C1”,“C2”)顯示()+ - - - + - - - +| C1 | C2 |+ - - - + - - - +| | 1 || | 1 || | 3 |+ - - - + - - - +