马上注册,结交更多数据大咖,获取更多知识干货,轻松玩转大数据
您需要 登录 才可以下载或查看,没有帐号?立即注册
x
本帖最后由 168主编 于 2015-8-18 20:38 编辑
在使用 Spark 1.4.1 的java api 时:
javaRdd是有个map方法的,
map(Function<T,R> f)
Return a new RDD by applying a function to all elements of this RDD.
只有一个参数为 Function接口 可以用 java lamda表达式实现。
但是DataFrame 的 map 方法在api中是这样的:
| map(scala.Function1<Row,R> f, scala.reflect.ClassTag<R> evidence$3)
Returns a new RDD by applying a function to all rows of this DataFrame. |
后一个参数 可以 scala.reflect.ClassTag$.MODULE$.apply(R.class) 获得。
对于前一个参数 不为 接口,不可使用lamda 实现,不知该如何实现.
求教
|