registerJavaUDAF (UDFRegistration)

Regista uma função agregada Java definida pelo utilizador como uma função SQL.

Sintaxe

registerJavaUDAF(name, javaClassName)

Parâmetros

Parâmetro Tipo Descrição
name str Nome da função agregada definida pelo utilizador.
javaClassName str Nome totalmente qualificado da classe Java.

Devoluções

None

Exemplos

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