Taskid dans MapReduce

Question

Je suis novice à la programmation MapReduce et Java. J'essaye d'obtenir taskid de chaque fonction de map(). Fondamentalement, j'ai besoin d'utiliser taskid de chaque mappeur comme décalage pour aller chercher des données à partir d'un fichier commun.

S'il vous plaît aidez-moi à obtenir des tâches de carte() tâche individuelle.

Merci, Vanamala

Answer 1

Peut-être que son trop tard pour répondre, mais vous pouvez obtenir la tâche id tentative et la tâche id lorsque vous configurez votre carte en utilisant l'objet de contexte. Le getTaskAttemptID() fait juste cela pour vous.