sort

Devuelve un nuevo dataframe ordenado por las columnas especificadas.

Sintaxis

sort(*cols: Union[int, str, Column, List[Union[int, str, Column]]], **kwargs: Any)

Parámetros

Parámetro Tipo Descripción
cols int, str, list o Column, opcional lista de nombres de columna o columna o ordinales de columna por los que se va a ordenar.
ascending bool o list, opcional, predeterminado True booleano o lista de booleanos. Ordene ascendente frente a descendente. Especifique la lista para varios pedidos de ordenación. Si se especifica una lista, la longitud de la lista debe ser igual a la longitud de cols.

Devoluciones

DataFrame: DataFrame ordenado.

Notas

Un ordinal de columna comienza a partir de 1, que es diferente del basado en __getitem__0. Si un ordinal de columna es negativo, significa ordenar de forma descendente.

Ejemplos

from pyspark.sql import functions as sf
df = spark.createDataFrame([
    (2, "Alice"), (5, "Bob")], schema=["age", "name"])

df.sort(sf.asc("age")).show()
# +---+-----+
# |age| name|
# +---+-----+
# |  2|Alice|
# |  5|  Bob|
# +---+-----+

df.sort(df.age.desc()).show()
# +---+-----+
# |age| name|
# +---+-----+
# |  5|  Bob|
# |  2|Alice|
# +---+-----+

df.sort("age", ascending=False).show()
# +---+-----+
# |age| name|
# +---+-----+
# |  5|  Bob|
# |  2|Alice|
# +---+-----+

df = spark.createDataFrame([
    (2, "Alice"), (2, "Bob"), (5, "Bob")], schema=["age", "name"])
df.orderBy(sf.desc("age"), "name").show()
# +---+-----+
# |age| name|
# +---+-----+
# |  5|  Bob|
# |  2|Alice|
# |  2|  Bob|
# +---+-----+
  • Last updated on