alias (DataFrame)

Devuelve un nuevo dataframe con un conjunto de alias.

Sintaxis

alias(alias: str)

Parámetros

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