【文件属性】:
文件名称:ReduceMap:Java中的MapReduce
文件大小:25KB
文件格式:ZIP
更新时间:2021-05-10 09:43:13
mapreduce Java
ReduceMap
Java中的MapReduce
介绍
Java中的MapReduce,具有基本的master和worker实现。
项目结构
RPC框架
使用作为RPC框架。
protobuf3文件:
master.proto:定义主RPC方法,由工作人员调用。
worker.proto:定义工作程序RPC方法,由master调用。
protobuf生成的代码:在target / generated-sources /中(未上传)
掌握
Master.java:ReduceMap主实现。
MasterRPCClient.java:用于调用RPC方法。
MasterRPCServer.java:用于接收RPC请求。
WorkerManager.java:管理工人的状态。
工人
Worker.java:ReduceMap worker实现。
WorkerRPCClient.
【文件预览】:
ReduceMap-master
----.gitignore(323B)
----README.md(3KB)
----pom.xml(6KB)
----run-client.sh(102B)
----test()
--------mersenne_prime.py(698B)
----run-master.sh(102B)
----run-worker.sh(102B)
----src()
--------main()
----.idea()
--------encodings.xml(172B)
--------vcs.xml(180B)
--------compiler.xml(530B)