Aller au contenu principal

indice

Spécifie une indication sur le DataFrame actuel.

Syntaxe

hint(name: str, *parameters: Union["PrimitiveType", "Column", List["PrimitiveType"]])

parameter

parameter

Type

Description

name

str

Nom du conseil.

parameters

str, list, float ou int

Paramètres facultatifs.

parameter

Type

Description

name

str

Nom du conseil.

parameters

str, list, float ou int

Paramètres facultatifs.

Renvoie

DataFrame: DataFrame suggéré.

Exemples

Python
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 ...
# ...