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

Valores nulos e ausentes

• $minN filtra valores nulos e ausentes.

Considere a seguinte agregação que retorna o mínimo 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",
         minimumThreeScores:
            {
               $minN:
                  {
                     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. Estes valores são ignorados.

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

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

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

Comparação de acumuladores $minN e $bottomN

Ambos os acumuladores $minN e $bottomN podem obter resultados semelhantes.

Em geral:

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

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

• Use $bottomN 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 $minN como acumulador.

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

$minN é suportado como window operator.

Considerações sobre o limite de memória

Os pipelines de agregação que chamam $minN 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ínimo de três Scores para um único jogo

Você pode usar o acumulador $minN para encontrar o mínimo de três pontuações em um único jogo.

db.gamescores.aggregate( [
   {
      $match : { gameId : "G1" }
   },
   {
      $group:
         {
            _id: "$gameId",
            minScores:
               {
                  $minN:
                  {
                     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 $minN com input : ["$score","$playerId"].

• Usa $minN para retornar os três primeiros elementos de pontuação do jogo G1 com n : 3.

A operação retorna os seguintes resultados:

[
   {
      _id: 'G1',
      minScores: [ [ 1, 'PlayerD' ], [ 31, 'PlayerA' ], [ 33, 'PlayerB' ] ]
   }
]

Encontrar o mínimo de três documentos em vários jogos

Você pode usar o acumulador $minN para encontrar as pontuações mínimas n em cada jogo.

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

O exemplo de pipeline:

• Utiliza $group para agrupar os resultados por gameId.

• Usa $minN para retornar o mínimo de três elementos de pontuação para cada jogo com n: 3.

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

A operação retorna os seguintes resultados:

[
   {
      _id: 'G2',
      minScores: [ [ 10, 'PlayerA' ], [ 14, 'PlayerB' ], [ 66, 'PlayerC' ] ]
   },
   {
      _id: 'G1',
      minScores: [ [ 1, 'PlayerD' ], [ 31, 'PlayerA' ], [ 33, 'PlayerB' ] ]
   }
]

Cálculo de n 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:
            {
               $minN:
                  {
                     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 $minN 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: [ [ 10, 'PlayerA' ] ] },
   {
      _id: { gameId: 'G1' },
      gamescores: [ [ 1, 'PlayerD' ], [ 31, 'PlayerA' ], [ 33, 'PlayerB' ] ]
   }
]