【Spark】DataFrame和DataSet[T]无法使用m

2017-12-20  本文已影响43人  PowerMe

关于这个问题,这位大神写的很不错了:文章地址
其中提供了四种方法可以借鉴。
但是按照文中的方法二还是折腾了一下。这里补充一点,方法二的myfunction函数必须是有返回值的,不能是Unit类型,比如可以是String等基本类型和case class等Product类型,如果是写入es或者打印等没有返回的情况,可以任意返回一个字符串。

上一篇 下一篇

猜你喜欢

热点阅读