Spark自定义UDAF函数（强类型-DSL语法）_spark udaf may[string,string]-CSDN博客

网友收藏2024-01-21 12:50

链接地址：https://blog.csdn.net/CyAurora/article/details/119790290
链接标题：Spark自定义UDAF函数（强类型-DSL语法）_spark udaf may[string,string]-CSDN博客
所属网站：blog.csdn.net
被收藏次数：2730

文章浏览阅读203次。1.继承Aggregator2.实现方法3.注册函数4.通过DataSet数据集获取结果package com.wxx.bigdata.sql03 import org.apache.spark.sql.{Encoders, SparkSession}import org.apache.spark.sql.expressions.Aggregator object CustomerUDAFClassAPP { def main(args: Array[String]): Unit _spark udaf may[string,string]

本文地址：https://tebull.com/detail/462169.html

标签：spark udaf may[string string]