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