指定当前 DataFrame 上的一些提示。
Syntax
hint(name: str, *parameters: Union["PrimitiveType", "Column", List["PrimitiveType"]])
参数
| 参数 | 类型 | 说明 |
|---|---|---|
name |
str | 提示的名称。 |
parameters |
str、list、float 或 int | 可选参数。 |
退货
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 ...
# ...