중복 항목을 유지하면서 이 DataFrame과 다른 DataFrame 모두에 행이 포함된 새 DataFrame을 반환합니다.
문법
intersectAll(other: "DataFrame")
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
other |
DataFrame | 결합해야 하는 또 다른 데이터 프레임입니다. |
Returns
DataFrame: 결합된 데이터 프레임입니다.
Notes
이는 SQL에서와 INTERSECT ALL 동일합니다. SQL의 표준으로, 이 함수는 이름이 아닌 위치별로 열을 확인합니다.
예제
df1 = spark.createDataFrame([("a", 1), ("a", 1), ("b", 3), ("c", 4)], ["C1", "C2"])
df2 = spark.createDataFrame([("a", 1), ("a", 1), ("b", 3)], ["C1", "C2"])
result_df = df1.intersectAll(df2).sort("C1", "C2")
result_df.show()
# +---+---+
# | C1| C2|
# +---+---+
# | a| 1|
# | a| 1|
# | b| 3|
# +---+---+
df1 = spark.createDataFrame([(1, "A"), (2, "B")], ["id", "value"])
df2 = spark.createDataFrame([(2, "B"), (3, "C")], ["id", "value"])
result_df = df1.intersectAll(df2).sort("id", "value")
result_df.show()
# +---+-----+
# | id|value|
# +---+-----+
# | 2| B|
# +---+-----+