メインコンテンツまでスキップ

exceptAll

このDataFrameに含まれる行のうち、他のデータフレームには含まれない行を、重複を保持したまま新しいDataFrame DataFrame返します。

構文

exceptAll(other: "DataFrame")

パラメーター

パラメーター

Type

説明

other

データフレーム

比較対象となるもう一方のDataFrame 。

戻り値

DataFrame

注意

これはSQLのEXCEPT ALLに相当します。SQLの標準機能として、この関数は列を位置に基づいて解決します(名前に基づいて解決するわけではありません)。

Python
df1 = spark.createDataFrame(
[("a", 1), ("a", 1), ("a", 1), ("a", 2), ("b", 3), ("c", 4)], ["C1", "C2"])
df2 = spark.createDataFrame([("a", 1), ("b", 3)], ["C1", "C2"])
df1.exceptAll(df2).show()
# +---+---+
# | C1| C2|
# +---+---+
# | a| 1|
# | a| 1|
# | a| 2|
# | c| 4|
# +---+---+