현재 DataFrame에 대한 힌트를 지정합니다.
문법
hint(name: str, *parameters: Union["PrimitiveType", "Column", List["PrimitiveType"]])
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
name |
str | 힌트의 이름입니다. |
parameters |
str, list, float 또는 int | 선택적 매개 변수입니다. |
Returns
DataFrame: 힌트 데이터 프레임입니다.
예제
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df2 = spark.createDataFrame([Row(height=80, name="Tom"), Row(height=85, name="Bob")])
df.join(df2, "name").explain()
# == Physical Plan ==
# ...
# ... +- SortMergeJoin ...
# ...
df.join(df2.hint("broadcast"), "name").explain()
# == Physical Plan ==
# ...
# ... +- BroadcastHashJoin ...
# ...