<强>作者|白松
<强>注:本文为原创,引用转载需与数澜联系。
1, org.apache.giraph.bsp。CentralizedService接口
<强>功能:基本服务接口共享CentralizedServiceMaster和CentralizedServiceWorker。
2, org.apache.giraph.bsp.CentralizedServiceMaster接口
<强>功能:最多,alt=" Giraph源码分析(二)——启动主/工人服务">
<强>功能:用于加载顶点或边输入分裂,每个线程都有一个WorkerClientRequestProcessor实例(实为NettyWorkerClientRequestProcessor对象),负责向远端的工人发送数据。
NettyWorkerClientRequestProcessor对象用于发送的WorkerClient对象就是BspServiceWorker里面的WorkerClient对象。
VertexInputSplitsCallable类中的readInputSplit()方法用来从分手中读取顶点的信息,然后调用NettyWorkerClientRequestProcessor对象的sendVertexRequest()方法把顶点发送到它所属的分区上。
8, org.apache.giraph.graph。ComputeCallable类,继承可调用的接口。
在该对象中完成“计算,通信——同步”的过程。每个线程都有一个WorkerClientRequestProcessor实例(实为NettyWorkerClientRequestProcessor对象),负责向远端的工人发送数据。
