我正在尝试在 erlang 中为 riak 编写一个 mapreduce 查询，但我无法理解它。有谁知道我在哪里可以找到一个 erlang mapreduce 查询的例子，或者可以写一个，它将执行相当于一个计数操作的 SQL？如果有人也可以逐行解释实际查询的作用，那也会很有帮助。我已经设法用 js 编写了一个，但是 erlang 完全不同。谢谢你。
问问题
1417 次
2 回答
1
Riak 带有一组在 Erlang 中实现的预定义 mapreduce 函数，如果您尝试编写自己的函数，可以将其用作指南。提供的函数之一是 reduce_count_inputs，它计算输入（只要输入不是整数）并且可能对您的场景有用。
我还创建了一个用 Erlang 实现的映射阶段函数库，您可以查看。
虽然我相信可以将 Erlang 函数作为 mapreduce 作业规范的一部分以类似于发送匿名 JavaScript 函数的方式传递，但通常不建议这样做，我自己也没有这样做。
于 2012-12-11T13:16:28.720 回答
0
I always look into riak sources to find some good examples. Here module which implement standard mapreduce funs: riak_kv_mapreduce This is a simples one, which just returns value of the object.
于 2012-12-12T07:58:37.137 回答