Hadoop IPC 连接的建立


Hadoop 2.x


相关参数说明

  • connections 用于保存ConnectionId到Connection的映射,位于org.apache.hadoop.ipc.Client中
    1
    private ConcurrentMap<Client.ConnectionId, Client.Connection> connections;
  • calls 当前正在处理的远程调用,位于org.apache.hadoop.ipc.Client.Connection中
    1
    private Hashtable<Integer, Client.Call> calls = new Hashtable();
  • shouldCloseConnection 连接关闭标志
    1
    private AtomicBoolean shouldCloseConnection = new AtomicBoolean();
Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×