2010-07-08 8 views
0

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é

Répondre

0

Cela a fonctionné pour moi: jobconf.getInt ("mapred.task.partition", 0); dans le réducteur.