TP2 - MapReduce sur MongoDB

Exemple 1

Dans l’exemple qui suit, nous allons chercher à calculer le nombre d’hommes et de femmes.

Tout d’abord, on définit la fonction map(), qui émettra un couple (sexe, 1), pour chaque sportif.

var map1 = function() {
    emit(this.Sexe, 1)
};

Ensuite, nous définissons la fonction reduce(), qui fera la somme des valeurs (qui seront tous des 1 donc).

var red1 = function(key, values) {
    return Array.sum(values);
};

Ensuite, nous faisons appel à la fonction mapReduce() sur notre collection.

db.Sportifs.mapReduce(
    map1,
    red1,
    { out: { inline: 1 } }
)

On remarque qu’on a m et M. On peut résoudre ce problème en faisant une transformation (en majuscule ou en minuscule) dans la fonction map().

var map1 = function() {
    emit(this.Sexe.toUpperCase(), 1)
}

Au final, on peut aussi tout déclarer dans la fonction mapReduce(), en utilisant le principe des fonctions anonymes.

db.Sportifs.mapReduce(
    function() {
        emit(this.Sexe.toUpperCase(), 1)
    },
    function(key, values) {
        return Array.sum(values);
    },
    { out: { inline: 1 } }
)

Exemple 2

Si on cherche à calculer le nombre de sportifs jouant pour chaque sport, il faut émettre des couples (sport, 1) pour chaque sport joué, pour chaque sportif. Mais il faut d’une part prendre en compte qu’il existe des sportifs dans la base, qui ne joue aucun sport. Et d’autre part que pour certains sportifs, il n’y a qu’un sport, et que dans ce cas, nous avons juste une chaîne et non un tableau.

db.Sportifs.mapReduce(
    function() {
        if (this.Sports) { // le sportif joue
            if (typeof this.Sports.Jouer != "string") {
                for (sp of this.Sports.Jouer) {
                    emit(sp, 1)
                }
            } else {
                emit(this.Sports.Jouer, 1)
            }
        }
    },
    function(key, values) {
        return Array.sum(values);
    },
    { out: { inline: 1 } }
)