新手求问spark# DataSciences - 数据科学
s*h
1 楼
最近在看spark的programming guide, https://spark.apache.org/docs/latest/
programming-guide.html#transformations
下面这段不是很明白啊。
accum = sc.accumulator(0)
data.map(lambda x => acc.add(x); f(x))
这里acc大概是typo,应该是accum吧。
但是为什么map后面有lambda和f(x)两个函数？
我简单查了一些例子，map后面似乎都只使用了一个函数。
那这个例子里面除了lambda的累加x的结果之外还有什么？
多谢
programming-guide.html#transformations
下面这段不是很明白啊。
accum = sc.accumulator(0)
data.map(lambda x => acc.add(x); f(x))
这里acc大概是typo,应该是accum吧。
但是为什么map后面有lambda和f(x)两个函数？
我简单查了一些例子，map后面似乎都只使用了一个函数。
那这个例子里面除了lambda的累加x的结果之外还有什么？
多谢