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.
Toplama işlevi: ikili KllFloatsSketch gösterimlerini birleştirir ve birleştirilmiş taslağı döndürür. İsteğe bağlı k parametresi, birleştirilmiş taslağın boyutunu ve doğruluğunu denetler (aralık 8-65535). k belirtilmezse, birleştirilen taslak ilk giriş taslağından k değerini benimser.
Sözdizimi
from pyspark.sql import functions as dbf
dbf.kll_merge_agg_float(col=<col>, k=<k>)
Parametreler
| Parametre | Türü | Description |
|---|---|---|
col |
pyspark.sql.Column veya sütun adı |
İkili KllFloatsSketch gösterimlerini içeren sütun. |
k |
pyspark.sql.Column veya intveya isteğe bağlı |
Boyutu ve doğruluğu denetleen k parametresi (8-65535 aralığı). |
İade
pyspark.sql.Column: KllFloatsSketch'in birleştirilmiş ikili gösterimi.
Örnekler
from pyspark.sql import functions as dbf
df1 = spark.createDataFrame([1.0,2.0,3.0], "FLOAT")
df2 = spark.createDataFrame([4.0,5.0,6.0], "FLOAT")
sketch1 = df1.agg(dbf.kll_sketch_agg_float("value").alias("sketch"))
sketch2 = df2.agg(dbf.kll_sketch_agg_float("value").alias("sketch"))
merged = sketch1.union(sketch2).agg(dbf.kll_merge_agg_float("sketch").alias("merged"))
n = merged.select(dbf.kll_sketch_get_n_float("merged")).first()[0]
n
6