registerJavaUDAF (UDFRegistration)

Registra una función de agregado definida por el usuario Java como una función SQL.

Sintaxis

registerJavaUDAF(name, javaClassName)

Parámetros

Parámetro Tipo Descripción
name str Nombre de la función de agregado definida por el usuario.
javaClassName str Nombre completo de la clase Java.

Devoluciones

None

Ejemplos

spark.udf.registerJavaUDAF("javaUDAF", "test.org.apache.spark.sql.MyDoubleAvg")
df = spark.createDataFrame([(1, "a"), (2, "b"), (3, "a")], ["id", "name"])
df.createOrReplaceTempView("df")
q = "SELECT name, javaUDAF(id) as avg from df group by name order by name desc"
spark.sql(q).collect()
# [Row(name='b', avg=102.0), Row(name='a', avg=102.0)]
  • Last updated on