MapReduce：将另一个桶中的对象映射到键列表（没有链接步行）？

Question

编辑：看起来这个概念被称为“转发和收集”。看看这在 Riak-Java 客户端中是如何工作的。

现在在 Riak 中执行一个简单的 MapReduce，它返回 User 对象的键列表。为了简单起见，我想简单地将 User 的值映射到键并返回用户列表。这是到目前为止我在 Scala 中所得到的（使用 Java 客户端），仅供参考，密钥是复合的，看起来像 clientId-userId：

val map = new JSSourceFunction("""
      function(riakObject){ 
            var rolek = riakObject.key;   
            return [rolek];
          }
    """)
        val reduce = new JSSourceFunction("""
      function(value){ 
            var returnValue=[], splitarr=[];  
            for(i=0;i<value.length;i++){ 
              splitarr=String(value[i]).split("-"); 
              returnValue = returnValue.concat([splitarr[1]]);  
            } 
            return returnValue; 
          }
    """)
    DB.client.mapReduce("rolesOfClientAdmins")
    .addKeyFilter(new TokenizeFilter("-", 1))
    .addKeyFilter(new MatchFilter(clientId))
    .addMapPhase(map)
    .addReducePhase(reduce)
    .execute().getResult(classOf[String])

我是否在 Reduce 阶段之后添加另一个 Map 阶段？我需要以某种方式更换水桶吗？感谢您的帮助！

Answer 1

我们从 rolesOfClientAdmins 存储桶作为输入开始，然后拆分键以获取 User 对象的 ID。然后将存储桶名称“users”和用户 ID 传递到下一个映射阶段。

val mapRolesBucket = new JSSourceFunction("""
      function(value){
            var splitarr=value.key.split('-'); 
            return [[ 'users', splitarr[1] ]];
          }
    """)
val mapUsersBucket = new JSSourceFunction("""
      function(value){
            var obj = Riak.mapValuesJson(value)[0];
            return [ obj ];
          }
    """)
    DB.client.mapReduce("rolesOfClientAdmins")
    .addKeyFilter(new TokenizeFilter("-", 1))
    .addKeyFilter(new MatchFilter(clientId))
    .addMapPhase(mapRolesBucket)
    .addMapPhase(mapUsersBucket)
    .execute().getResult(classOf[String])