yaokai1117GUI & bug fix09f81a211 years agoHistory
37 lines · 1.4 KB · Objective-C
RawDownload
##########################################	The JobTracker module run the job.#	It assigns and coordinates all the tasktrackers.#	When the job is started, Jobtracker will produce mapperTasks and reducerTasks, and then shoot them to different tasktrackers.#	Jobtracker will monitor the states of tasktrackers and tasks, #	and do some steps ,such as change tasks to other tasktrackers if some tasks are failed or some tasktrackers are broken.#	#	@author Kai Yao(yaokai)#########################################JobTracker : module {		PATH : con "/appl/MR/mapreduce/jobtracker.dis"; 		init : fn(); 		submitJob : fn(config : ref Jobs->JobConfig) : int;		startJob : fn(id : int) : int; 		updateTaskTrackers : fn(taskTracker : ref MRUtil->TaskTrackerInfo) : int;		 ###### debug		getJob : fn(id : int) : ref Jobs->Job;		produceMapper : fn(job : ref Jobs->Job) : int;		produceReducer : fn(job : ref Jobs->Job) : int;						 		shootMapper : fn(mapper : ref MRUtil->MapperTask) : int;		shootReducer : fn(reducer : ref MRUtil->ReducerTask, mapperFileAddr : string) : int;######				mapperSucceed : fn(task : ref MRUtil->MapperTask, mapperFileAddr : string) : int;		reducerSucceed : fn(task : ref MRUtil->ReducerTask) : int;		mapperFailed : fn(task : ref MRUtil->MapperTask) : int;		reducerFailed : fn(task : ref MRUtil->ReducerTask) : int;		reducerFailedonMapper : fn(task : ref MRUtil->ReducerTask, failedAddr : string) : int;};