alias (DataFrame)
Renvoie un nouveau DataFrame avec un alias défini.
Syntaxe
alias(alias: str)
parameter
parameter | Type | Description |
|---|---|---|
| str | un nom d'alias à définir pour le DataFrame. |
Renvoie
DataFrame: DataFrame aliasé.
Exemples
Python
from pyspark.sql import functions as sf
df = spark.createDataFrame(
[(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
df_as1 = df.alias("df_as1")
df_as2 = df.alias("df_as2")
joined_df = df_as1.join(df_as2,
sf.col("df_as1.name") == sf.col("df_as2.name"), 'inner')
joined_df.select(
"df_as1.name", "df_as2.name", "df_as2.age"
).sort(sf.desc("df_as1.name")).show()
# +-----+-----+---+
# | name| name|age|
# +-----+-----+---+
# | Tom| Tom| 14|
# | Bob| Bob| 16|
# |Alice|Alice| 23|
# +-----+-----+---+