java - scalding 如何将用户函数传递给远程 MapReduce 节点

Question

使用 Scalding 时，您可以提供一个函数。我想知道 scalding 如何将这些功能传递给远程 map/reduce 任务？这是使用scala中的东西还是可以用匿名对象完成的通用东西？

score 3 · Accepted Answer

3

这是由 Cascading 完成的普通 Java 序列化。

于 2013-04-25T21:10:15.793 回答

score 1 · Accepted Answer

1

It uses Cascading, a java library upon Apache Hadoop.

于 2013-03-07T17:52:02.637 回答

2 回答 2