kll_sketch_agg_double
Fonction d'agrégation : renvoie la représentation binaire compacte du Datasketches KllDoublesSketch construit avec les valeurs de la colonne d'entrée. Le paramètre k optionnel contrôle la taille et la précision de l'esquisse (default 200, plage de 8 à 65535).
Syntaxe
Python
from pyspark.sql import functions as dbf
dbf.kll_sketch_agg_double(col=<col>, k=<k>)
parameter
parameter | Type | Description |
|---|---|---|
|
| La colonne contenant les valeurs doubles à agréger. |
|
| Le parameter k qui contrôle la taille et la précision (default 200, plage de 8 à 65 535). |
Renvoie
pyspark.sql.Column: La représentation binaire du KllDoublesSketch.
Exemples
Python
from pyspark.sql import functions as dbf
df = spark.createDataFrame([1.0,2.0,3.0,4.0,5.0], "DOUBLE")
result = df.agg(dbf.kll_sketch_agg_double("value")).first()[0]
result is not None and len(result) > 0
Output
True