5

他们是一种通过 java 驱动程序执行 MongoDB map reduce 作业的方法，您可以在其中创建包含函数的范围 DBObject。

我可以在 javascript 中执行我的 map reduce 配置，其中传入的范围包含实用程序函数，但我不知道如何使用 java 驱动程序执行此操作。

我使用 mapReduceCommand 设置范围

c.addExtraOption("scope",new BasicDBObject().append('average',function(){ return false;}));

但是，我无法让映射器/缩减器将范围组件“例如”平均值识别为一个函数。如果我使用引号，map reduce 上下文认为它是一个字符串，但如果不是，我似乎无法解析范围组件。

如何通过java驱动获取scope组件中的一个函数？

感谢Ren的回答，这是一个spring bean配置，用于为具有函数的mongodb java驱动程序设置范围。

    <util:map id="mrScope" 
              key-type="java.lang.String" 
              value-type="java.lang.Object">
    <entry key="buckets"><bean class="com.mongodb.util.JSON" factory-method="parse"><constructor-arg value="[0,10,15,20,25,30,35,40,45,50,55,60,65]"/></bean></entry>
    <entry key="average">
        <bean class="org.bson.types.CodeWScope">
            <constructor-arg value="function () {var s = 0;for (var i = 0; i &gt; arguments.length; i++) s += arguments[i];return s / arguments.length;}"/>
            <constructor-arg><bean class="org.bson.BasicBSONObject"/></constructor-arg>
        </bean>
    </entry>
4

3 回答 3

8

服务器代码会自动将 map 和 reduce 转换为 Javascript 函数，但范围不是这样。要在范围选项中传递函数，您可以这样做：

c.addExtraOption("scope", new BasicBSONObject("average",
  new CodeWScope("function(){ return false;}", new BasicBSONObject())));
于 2012-04-06T15:52:31.247 回答
1

对于那些难以使用 MongoTemplate 在范围内应用函数的人，下面的示例似乎有效：

    Map<String, Object> scopeVariables = new HashMap<>();
    String scopeFunction="function(){ //do something }";
    scopeVariables.put("transform", new CodeWScope(scopeFunction,new BasicBSONObject()));

    MapReduceOptions options = new MapReduceOptions();
    options.scopeVariables(scopeVariables);
    options.outputTypeInline();

    MapReduceResults<ValueObject> result = template.mapReduce("collection", mapFunction, reduceFunction, options, ValueObject.class);

运行上述代码后，transform() 函数将在 map 函数中可见：

var mapFunction=function(){  
  transform(); 
  emit(key,value); 
}
于 2016-10-17T13:12:49.780 回答
1

使用新的 api (3.0).. 我发现下面的选项正在工作

collection .mapReduce(map, reduce) .scope(new Document("key", value)) .limit(100);

于 2015-12-23T13:07:12.340 回答