开发者

Taskid in MapReduce

开发者 https://www.devze.com 2022-12-29 18:55 出处:网络
I am newbie to MapReduce and Java programming. I am trying to get taskid of each map() function. Basically I need to use taskid of each mapper as offset for fetching some data from a common file.

I am newbie to MapReduce and Java programming. I am trying to get taskid of each map() function. Basically I need to use taskid of each mapper as offset for fetching some data from a common file.

Plea开发者_StackOverflowse help me getting taskid of individual map() task.

Thanks, Vanamala


Maybe its too late to answer, but you can get the task attempt id and then task id when you set up your map using the Context object. The getTaskAttemptID() does just that for you.

0

精彩评论

暂无评论...
验证码 换一张
取 消