kll_merge_agg_float

Agregační funkce: slučuje binární reprezentaci KllFloatsSketch a vrátí sloučenou skicu. Volitelný parametr k řídí velikost a přesnost sloučené skicy (rozsah 8–65535). Pokud není zadaná hodnota k, sloučená skica převezme hodnotu k z prvního vstupního skica.

Syntaxe

from pyspark.sql import functions as dbf

dbf.kll_merge_agg_float(col=<col>, k=<k>)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column nebo název sloupce	Sloupec obsahující binární reprezentaci KllFloatsSketch.
k	pyspark.sql.Column nebo int, volitelné	Parametr k, který řídí velikost a přesnost (rozsah 8–65535).

Návraty

pyspark.sql.Column: Sloučená binární reprezentace KllFloatsSketch.

Examples

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