erlang - erlang での Map Reduce クエリ

Question

riak 用の erlang で mapreduce クエリを作成しようとしていますが、うまく理解できません。カウント操作に相当する SQL を実行する erlang mapreduce クエリの例をどこで見つけられるか、または記述できるかを知っている人はいますか? また、実際のクエリが行ごとに何をするかを誰かが説明してくれると助かります。私は js で書くことができましたが、erlang はかなり違います。ありがとうございました。

Answer 1

Riak には、Erlang で実装された事前定義された一連の mapreduce 関数が付属しており、独自の関数を作成しようとする場合のガイドとして使用できます。提供されている関数の 1 つは reduce_count_inputsで、これは (入力が整数でない限り) 入力をカウントし、シナリオに役立つ可能性があります。

また、Erlang で実装されたマップ フェーズ関数のライブラリも作成しました。これを参照してください。

匿名の JavaScript 関数を送信する方法と同様の方法で、mapreduce ジョブ仕様の一部として Erlang 関数を渡すことは可能だと思いますが、通常はお勧めしません。

Answer 2

私はいつも riak のソースを調べて、いくつかの良い例を見つけています。標準の mapreduce funs を実装するモジュール: riak_kv_mapreduce これは単純なもので、オブジェクトの値を返すだけです。