एकत्रीकरण पाइपलाइन से लौटाए गए परिणाम केवल सादे वस्तुएं हैं। तो आप छँटाई एक पाइपलाइन चरण के रूप में करते हैं, एक अलग ऑपरेशन के रूप में नहीं:
Recommend.aggregate(
[
// Grouping pipeline
{ "$group": {
"_id": '$roomId',
"recommendCount": { "$sum": 1 }
}},
// Sorting pipeline
{ "$sort": { "recommendCount": -1 } },
// Optionally limit results
{ "$limit": 5 }
],
function(err,result) {
// Result is an array of documents
}
);
तो ऐसे कई पाइपलाइन ऑपरेटर हैं जिनका उपयोग $group
. के लिए किया जा सकता है या $sort
या $limit
और अन्य चीजें भी। इन्हें किसी भी क्रम में, और जितनी बार आवश्यकता हो, प्रस्तुत किया जा सकता है। बस यह समझ लेना कि एक "पाइपलाइन" चरण प्रवाहित होकर अगले चरण में कार्य करता है।