$maxN (acúmulo de agregação)

Valores nulos e ausentes

• $maxN filtra valores nulos e ausentes.

Considere a seguinte agregação que retorna o máximo de n documentos de um grupo:

db.aggregate( [
   {
      $documents: [
         { playerId: "PlayerA", gameId: "G1", score: 1 },
         { playerId: "PlayerB", gameId: "G1", score: 2 },
         { playerId: "PlayerC", gameId: "G1", score: 3 },
         { playerId: "PlayerD", gameId: "G1" },
         { playerId: "PlayerE", gameId: "G1", score: null }
      ]
   },
   {
      $group:
      {
         _id: "$gameId",
         maximumThreeScores:
            {
               $maxN:
                  {
                     input: "$score",
                     n: 4
                  }
            }
      }
   }
] )

Neste exemplo:

• $documents cria os documentos literais que contêm as pontuações dos jogadores.

• $group agrupa os documentos por gameId. Este exemplo tem apenas um gameId, G1.

• PlayerD tem uma pontuação ausente e PlayerE tem um nulo score. Esses valores são considerados nulos.

• O campo maximumThreeScores é especificado como $maxN com input : "$score" e retornado como uma array.

• Como há apenas 3 documentos com scores maxN retorna o máximo de 3 campos score , mesmo que n = 4.

[
   {
   _id: 'G1',
   maximumThreeScores: [ 3, 2, 1 ]
   }
]

Comparação de $maxN $topN acumuladorese

Ambos os acumuladores $maxN e $topN podem obter resultados semelhantes.

Em geral:

• $maxN tem a vantagem de encontrar valores máximos em nenhuma ordem de classificação específica. Se você quiser saber os valores máximos para n documentos, use $maxN.

• Se garantir uma ordem de classificação específica for um requisito, use $topN.

• Use $topN se não pretende classificar os valores de saída.

Suporte para função de janela e expressão de agregação

Você pode usar $maxN como acumulador.

$maxN é suportado como uma expressão de aggregation.

$maxN é suportado como window operator.

Considerações sobre o limite de memória

Os pipelines de agregação que chamam $maxN estão sujeitos ao limite de 100 MB. Se esse limite for excedido para um grupo individual, a agregação falhará com um erro.

Encontre o máximo de três Scores para um único jogo

Você pode usar o acumulador $maxN para encontrar o máximo de três pontuações em um único jogo.

db.gamescores.aggregate( [
   {
      $match : { gameId : "G1" }
   },
   {
      $group:
         {
            _id: "$gameId",
            maxThreeScores:
               {
                  $maxN:
                  {
                     input: ["$score","$playerId"],
                     n:3
                  }
               }
         }
   }
] )

O exemplo de pipeline:

• Utiliza $match para filtrar os resultados em um único gameId. Neste caso, G1.

• Utiliza $group para agrupar os resultados por gameId. Neste caso, G1.

• Especifica os campos que são entrada para $maxN com input : ["$score","$playerId"].

• Usa $maxN para retornar o máximo de três elementos de pontuação para o jogo G1 com n : 3.

A operação retorna os seguintes resultados:

[
   {
      _id: 'G1',
      maxThreeScores: [ [ 99, 'PlayerC' ], [ 33, 'PlayerB' ], [ 31, 'PlayerA' ] ]
   }
]

Encontrar o máximo de três pontuações em vários jogos

Você pode usar o acumulador $maxN para encontrar as pontuações máximas n em cada jogo.

db.gamescores.aggregate( [
   {
      $group:
      {
         _id: "$gameId",
         maxScores:
            {
               $maxN:
                  {
                     input: ["$score","$playerId"],
                     n: 3
                  }
            }
      }
   }
] )

O exemplo de pipeline:

• Utiliza $group para agrupar os resultados por gameId.

• Usa $maxN para retornar o máximo de três elementos de pontuação para cada jogo com n: 3.

• Especifica os campos que são entrada para $maxN com input: ["$score","$playerId"].

A operação retorna os seguintes resultados:

[
   {
      _id: 'G1',
      maxScores: [ [ 99, 'PlayerC' ], [ 33, 'PlayerB' ], [ 31, 'PlayerA' ] ]
   },
   {
      _id: 'G2',
      maxScores: [ [ 80, 'PlayerD' ], [ 66, 'PlayerC' ], [ 14, 'PlayerB' ] ]
   }
]

Cálculo n de com base na chave de grupo para $group

Você também pode atribuir o valor de n dinamicamente. Neste exemplo, a expressão $cond é utilizada no campo gameId .

db.gamescores.aggregate([
   {
      $group:
      {
         _id: {"gameId": "$gameId"},
         gamescores:
            {
               $maxN:
                  {
                     input: ["$score","$playerId"],
                     n: { $cond: { if: {$eq: ["$gameId","G2"] }, then: 1, else: 3 } }
                  }
            }
      }
   }
] )

O exemplo de pipeline:

• Utiliza $group para agrupar os resultados por gameId.

• Especifica os campos que entram para $maxN com input : ["$score","$playerId"] .

• Se gameId for G2 então n é 1, caso contrário n é 3.

A operação retorna os seguintes resultados:

[
   { _id: { gameId: 'G2' }, gamescores: [ [ 80, 'PlayerD' ] ] },
   {
      _id: { gameId: 'G1' },
      gamescores: [ [ 99, 'PlayerC' ], [ 33, 'PlayerB' ], [ 31, 'PlayerA' ] ]
   }
]