Hadoop源码分析之心跳机制
实我觉得分析到这里大家就可以自己分析了，jobClient也是一个协议：
代码五：
- InterTrackerProtocol jobClient;
该协议用于定义Tasktracker和Jobtracker的通信。同样，它也是一个代理对象：
代码六：
- this.jobClient = (InterTrackerProtocol)
- UserGroupInformation.getLoginUser().doAs(
- new PrivilegedExceptionAction<Object>() {
- public Object run() throws IOException {
- return RPC.waitForProxy(InterTrackerProtocol.class,
- InterTrackerProtocol.versionID,
- jobTrackAddr, fConf);
- }
- });
终于，hadoop底层通信整个系列的源码分析全部完成了。我可以好好地复习学校的功课了。呵呵。
原文链接：http://www.blogjava.net/jlins-you/archive/2012/05/31/379603.html