# Functions
分布式执行mapReduce任务,通过rpc在主服务器上注册的workers调度map和reduce任务.
nReduce 当前map执行的reduce编号
从输入文件infile中读取内容
通过mapF对内容进行处理,分割map输出
将指定文件结果解析为key/value
创建nReduce个中间文件名称
*/.
No description provided by the author
自定义map func.
No description provided by the author
自定义reduce func.
中间文件名称.
启动worker,与master建立链接.
设置worker标识.
# Constants
No description provided by the author
# Structs
任务参数结构,存储任务相关的信息.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
工作者,等待DOTask任务或者shutDown任务.