关于这个问题,这位大神写的很不错了:文章地址
其中提供了四种方法可以借鉴。
但是按照文中的方法二还是折腾了一下。这里补充一点,方法二的myfunction函数必须是有返回值的,不能是Unit类型,比如可以是String等基本类型和case class等Product类型,如果是写入es或者打印等没有返回的情况,可以任意返回一个字符串。
关于这个问题,这位大神写的很不错了:文章地址
其中提供了四种方法可以借鉴。
但是按照文中的方法二还是折腾了一下。这里补充一点,方法二的myfunction函数必须是有返回值的,不能是Unit类型,比如可以是String等基本类型和case class等Product类型,如果是写入es或者打印等没有返回的情况,可以任意返回一个字符串。
本文标题:【Spark】DataFrame和DataSet[T]无法使用m
本文链接:https://www.haomeiwen.com/subject/podnwxtx.html
网友评论