$ アキュムレータ （アキュムレータ演算子）

{ _id: 'a' },
{ _id: 'b' },
{ _id: 'c' }
...
{ _id: 'z' }

[
   {
      $sort: { _id: 1 }
   },
   {
      $group: {
         _id: null,
         alphabet: {
            $accumulator: {
               init: function() {
                  return ""
               },
               accumulate: function(state, letter) {
                  return(state + letter)
               },
               accumulateArgs: [ "$_id" ],
               merge: function(state1, state2) {
                  return(state1 + state2)
               },
               lang: "js"
            }
         }
      }
   }
]

db.books.insertMany([
  { _id: 8751, title: "The Banquet", author: "Dante", copies: 2 },
  { _id: 8752, title: "Divine Comedy", author: "Dante", copies: 1 },
  { _id: 8645, title: "Eclogues", author: "Dante", copies: 2 },
  { _id: 7000, title: "The Odyssey", author: "Homer", copies: 10 },
  { _id: 7020, title: "Iliad", author: "Homer", copies: 10 }
])

db.books.aggregate([
{
  $group :
  {
    _id : "$author",
    avgCopies:
    {
      $accumulator:
      {
        init: function() {                        // Set the initial state
          return { count: 0, sum: 0 }
        },
        accumulate: function(state, numCopies) {  // Define how to update the state
          return {
            count: state.count + 1,
            sum: state.sum + numCopies
          }
        },
        accumulateArgs: ["$copies"],              // Argument required by the accumulate function
        merge: function(state1, state2) {         // When the operator performs a merge,
          return {                                // add the fields from the two states
            count: state1.count + state2.count,
            sum: state1.sum + state2.sum
          }
        },
        finalize: function(state) {               // After collecting the results from all documents,
          return (state.sum / state.count)        // calculate the average
        },
        lang: "js"
      }
    }
  }
}
])

db.restaurants.insertMany( [
  { _id: 1, name: "Food Fury", city: "Bettles", cuisine: "American" },
  { _id: 2, name: "Meal Macro", city: "Bettles", cuisine: "Chinese" },
  { _id: 3, name: "Big Crisp", city: "Bettles", cuisine: "Latin" },
  { _id: 4, name: "The Wrap", city: "Onida", cuisine: "American" },
  { _id: 5, name: "Spice Attack", city: "Onida", cuisine: "Latin" },
  { _id: 6, name: "Soup City", city: "Onida", cuisine: "Chinese" },
  { _id: 7, name: "Crave", city: "Pyote", cuisine: "American" },
  { _id: 8, name: "The Gala", city: "Pyote", cuisine: "Chinese" }
] )

1
db.restaurants.aggregate([
2
{
3
  $group :
4
  {
5
    _id : { city: "$city" },
6
    restaurants:
7
    {
8
      $accumulator:
9
      {
10
        init: function(city, userProfileCity) {        // Set the initial state
11
          return {
12
            max: city === userProfileCity ? 3 : 1,     // If the group matches the user's city, return 3 restaurants
13
            restaurants: []                            // else, return 1 restaurant
14
          }
15
        },
16
17
        initArgs: ["$city", <userProfileCity>],        // Argument to pass to the init function
18
19
        accumulate: function(state, restaurantName) {  // Define how to update the state
20
          if (state.restaurants.length < state.max) {
21
            state.restaurants.push(restaurantName);
22
          }
23
          return state;
24
        },
25
26
        accumulateArgs: ["$name"],                     // Argument required by the accumulate function
27
28
        merge: function(state1, state2) {
29
          return {
30
            max: state1.max,
31
            restaurants: state1.restaurants.concat(state2.restaurants).slice(0, state1.max)
32
          }
33
        },
34
35
        finalize: function(state) {                   // Adjust the state to only return field we need
36
          return state.restaurants
37
        }
38
39
        lang: "js"
40
      }
41
    }
42
  }
43
}
44
])