$bottom(集計アキュムレータ)
定義
構文
{ $bottom: { sortBy: { <field1>: <sort order>, <field2>: <sort order> ... }, output: <expression> } }
フィールド | 必要性 | 説明 |
---|---|---|
sortBy | 必須 | |
出力 | 必須 | グループ内の各要素の出力を表し、任意の 式 にすることができます。 |
動作
NULL および欠損値
スコアのグループから最下位のドキュメントを返す次の集計を検討します。
$bottom
は、null 値をフィルタリングで除外しません。$bottom
欠落値を null に変換します。
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: { $bottom: { output: [ "$playerId", "$score" ], sortBy: { "score": -1 } } } } } ] )
この例では、次のことが行われます。
$documents
は、プレイヤーのスコアを含むリテラル ドキュメントを作成します。$group
はドキュメントをgameId
でグループ化します。 この例ではgameId
、G1
は 1 つのみです。PlayerD
はスコアが欠落しており、PlayerE
には nullscore
があります。 これらの値は両方とも null と見なされます。playerId
フィールドとscore
フィールドはoutput : ["$playerId"," $score"]
として指定され、配列値として返されます。sortBy: { "score": -1 }
で並べ替え順序を指定します。PlayerD
最下位要素には とPlayerE
が関連付けられています。PlayerD
は最低のscore
として返されます。複数の null 値に対してより明確な同点動作を実現するには、
sortBy
にフィールドを追加します。
[ { _id: 'G1', playerId: [ 'PlayerD', null ] } ]
制限事項
ウィンドウ関数と集計式のサポート
$bottom
集計式としてサポートされていません。
$bottom
はwindow operator
としてサポートされています。
メモリ制限に関する考慮事項
$bottom
を呼び出す集計パイプラインには100 MB の制限が適用されます。 個々のグループでこの制限を超えると、集計はエラーで失敗します。
例
以下のドキュメントを持つgamescores
コレクションを考えてみましょう。
db.gamescores.insertMany([ { playerId: "PlayerA", gameId: "G1", score: 31 }, { playerId: "PlayerB", gameId: "G1", score: 33 }, { playerId: "PlayerC", gameId: "G1", score: 99 }, { playerId: "PlayerD", gameId: "G1", score: 1 }, { playerId: "PlayerA", gameId: "G2", score: 10 }, { playerId: "PlayerB", gameId: "G2", score: 14 }, { playerId: "PlayerC", gameId: "G2", score: 66 }, { playerId: "PlayerD", gameId: "G2", score: 80 } ])
下部を検索 Score
$bottom
アキュムレータを使用して、1 つのゲームの最低スコアを見つけることができます。
db.gamescores.aggregate( [ { $match : { gameId : "G1" } }, { $group: { _id: "$gameId", playerId: { $bottom: { output: [ "$playerId", "$score" ], sortBy: { "score": -1 } } } } } ] )
サンプル パイプライン:
$match
を使用して結果を単一のgameId
でフィルタリングします。 この場合は、G1
ます。$group
を使用して結果をgameId
でグループ化します。 この場合は、G1
ます。を使用して
$bottom
output : ["$playerId"," $score"]
の出力するフィールドを指定します。スコアを降順で並べ替えるには、
sortBy: { "score": -1 }
を使用します。ゲームの最下位スコアを返すには、
$bottom
を使用します。
この操作は次の結果を返します。
[ { _id: 'G1', playerId: [ 'PlayerD', 1 ] } ]
Score
複数のゲームにわたって最下位の を見つける
$bottom
アキュムレータを使用して、各ゲームの最下位であるscore
を見つけることができます。
db.gamescores.aggregate( [ { $group: { _id: "$gameId", playerId: { $bottom: { output: [ "$playerId", "$score" ], sortBy: { "score": -1 } } } } } ] )
サンプル パイプライン:
$group
を使用して結果をgameId
でグループ化します。$bottom
を使用して、各ゲームの最下位のscore
を返します。を使用して
$bottom
output : ["$playerId", "$score"]
の出力するフィールドを指定します。スコアを降順で並べ替えるには、
sortBy: { "score": -1 }
を使用します。
この操作は次の結果を返します。
[ { _id: 'G2', playerId: [ 'PlayerA', 10 ] }, { _id: 'G1', playerId: [ 'PlayerD', 1 ] } ]