lorsque je traite une paire clé-{ensemble de valeurs} donnée dans la fonction réducteur, comment puis-je obtenir le numéro de partition auquel cette paire de clés- {ensemble de valeurs} appartiennent à? Comment est-il possible d'obtenir ce numéro de partition sans ajouter d'informations supplémentaires sur le numéro de partition avec chaque paire clé-valeur lors du partitionnement? CheersObtenir le numéro de partition dans un réducteur auquel appartient une paire valeur/clé
0
A
Répondre
0
Cela a fonctionné pour moi: jobconf.getInt ("mapred.task.partition", 0); dans le réducteur.