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

Valores nulos e ausentes

Considere a seguinte agregação que retorna o documento superior de um grupo de pontuações:

• $top não filtra valores nulos.

• $top converte valores ausentes em nulo.

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",
         playerId:
            {
               $top:
                  {
                     output: [ "$playerId", "$score" ],
                     sortBy: { "score": 1 }
                  }
            }
      }
   }
] )

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.

• Os campos playerId e score são especificados como output : ["$playerId"," $score"] e retornados como valores de array.

• Especifique a ordem de classificação com sortBy: { "score": 1 }.

• PlayerD e PlayerE empatado para o elemento superior. PlayerD é retornado como o score superior.

• Para ter um comportamento de quebra de vínculo mais determinístico para vários valores nulos, adicione mais campos ao sortBy.

[
   {
      _id: 'G1',
      playerId: [ 'PlayerD', null ]
   }
]

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

$top não é suportado como uma expressão de agregação.

$top é suportado como um window operator.

Considerações sobre o limite de memória

Os pipelines de agregação que chamam $top 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 melhor Score

Você pode usar o acumulador $top para encontrar a melhor pontuação em um único jogo.

db.gamescores.aggregate( [
   {
      $match : { gameId : "G1" }
   },
   {
      $group:
         {
            _id: "$gameId",
            playerId:
               {
                  $top:
                  {
                     output: [ "$playerId", "$score" ],
                     sortBy: { "score": -1 }
                  }
               }
         }
   }
] )

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 de saída para $top com output : ["$playerId"," $score"].

• Utiliza sortBy: { "score": -1 } para classificar as pontuações em ordem decrescente.

• Usa $top para retornar a pontuação máxima do jogo.

A operação retorna os seguintes resultados:

[ { _id: 'G1', playerId: [ 'PlayerC', 99 ] } ]

Encontre os Score principais em vários jogos

Você pode usar o acumulador de $top para encontrar os score melhores em cada jogo.

db.gamescores.aggregate( [
      {
         $group:
         { _id: "$gameId", playerId:
            {
               $top:
                  {
                     output: [ "$playerId", "$score" ],
                     sortBy: { "score": -1 }
                  }
            }
         }
      }
] )

O exemplo de pipeline:

• Utiliza $group para agrupar os resultados por gameId.

• Usa $top para retornar o top score de cada jogo.

• Especifica os campos que são de saída para $top com output : ["$playerId", "$score"].

• Utiliza sortBy: { "score": -1 } para classificar as pontuações em ordem decrescente.

A operação retorna os seguintes resultados:

[
   { _id: 'G2', playerId: [ 'PlayerD', 80 ] },
   { _id: 'G1', playerId: [ 'PlayerC', 99 ] }
]