kll_sketch_agg_float

Fonction d'agrégation : renvoie la représentation binaire compacte du Datasketches KllFloatsSketch construite 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_float(col=<col>, k=<k>)

parameter

parameter	Type	Description
col	pyspark.sql.Column ou nom de colonne	La colonne contenant les valeurs flottantes à agréger.
k	pyspark.sql.Column ou int, facultatif	Le parameter k qui contrôle la taille et la précision (default 200, plage de 8 à 65 535).

parameter	Type	Description
col	pyspark.sql.Column ou nom de colonne	La colonne contenant les valeurs flottantes à agréger.
k	pyspark.sql.Column ou int, facultatif	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 KllFloatsSketch.

Exemples

Python

from pyspark.sql import functions as dbf
df = spark.createDataFrame([1.0,2.0,3.0,4.0,5.0], "FLOAT")
result = df.agg(dbf.kll_sketch_agg_float("value")).first()[0]
result is not None and len(result) > 0

Output

True