Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
Gruptaki son değeri döndürür. İşlev varsayılan olarak gördüğü son değerleri döndürür. IgnoreNulls değeri true olarak ayarlandığında gördüğü son null olmayan değeri döndürür. Tüm değerler null ise null döndürülür. sonuçları, bir karıştırmadan sonra belirlenemeyen satırların sırasına bağlı olduğundan işlev belirleyici değildir.
Sözdizimi
from pyspark.sql import functions as sf
sf.last(col, ignorenulls=False)
Parametreler
| Parametre | Türü | Description |
|---|---|---|
col |
pyspark.sql.Column veya sütun adı |
Son değerin getirilmeye hazır olduğu sütun. |
ignorenulls |
bool | Son değer null ise null olmayan değeri arayın. Varsayılan olarak yanlıştır. |
İade
pyspark.sql.Column: grubun son değeri.
Örnekler
from pyspark.sql import functions as sf
df = spark.createDataFrame([("Alice", 2), ("Bob", 5), ("Alice", None)], ("name", "age"))
df = df.orderBy(df.age.desc())
df.groupby("name").agg(sf.last("age")).orderBy("name").show()
+-----+---------+
| name|last(age)|
+-----+---------+
|Alice| NULL|
| Bob| 5|
+-----+---------+
Null değerleri yoksaymak için olarak ignorenullsayarlayınTrue:
df.groupby("name").agg(sf.last("age", ignorenulls=True)).orderBy("name").show()
+-----+---------+
| name|last(age)|
+-----+---------+
|Alice| 2|
| Bob| 5|
+-----+---------+