Final Exam M101P Q2.

finalQ2.js

use enron
db.messages.aggregate([
{'$project' : {'_id' : '$_id' , 'From' : '$headers.From', 'To' : '$headers.To'}},
{'$unwind' : '$To'},
{'$group' : {'_id' : {'_id' : '$_id', 'From' : '$From'}, 'To' : {'$addToSet' : '$To'}}},
{'$unwind' : '$To'},
{'$group' : {'_id' : {'From' : '$_id.From', 'To' : '$To'}, 'emails' : {'$sum' : 1}}},
{'$sort' : {'emails' : -1}},
{'$limit' : 5}
])