Oharra
Baimena behar duzu orria atzitzeko. Direktorioetan saioa has dezakezu edo haiek alda ditzakezu.
Baimena behar duzu orria atzitzeko. Direktorioak alda ditzakezu.
Devuelve un nuevo dataframe con un conjunto de alias.
Sintaxis
alias(alias: str)
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
alias |
str | un nombre de alias que se va a establecer para dataframe. |
Devoluciones
DataFrame: DataFrame con alias.
Ejemplos
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|
# +-----+-----+---+