当使用滚烫时,您可以提供一个函数。我想知道scalding是如何将这些函数传递给远程map/reduce任务的?这是使用scala中的一些东西,还是可以用匿名对象完成的一些通用的东西?
发布于 2013-04-26 05:10:16
它是普通的老式Java序列化,它是通过级联来完成的。
发布于 2013-03-08 01:52:03
它使用的是Cascading,Apache Hadoop上的java库。
https://stackoverflow.com/questions/15277625
复制相似问题