240 发简信
古语1
IP属地：上海
  • Resize,w 360,h 240
    kafka生产消费

    produce客户端 produce服务端 consumer客户端 consumer服务端

    171 0 0
  • hdfs写之namenode端addBlock实现<五>

    一、流程图 二、NameNodeRpcServer的addBlock实现 1、客户端会通过addBlock方法通过rpc调用namenode方法...

    1018 0 0
  • hdfs写之DataXceiver线程<四>

    一、流程图 二、DataXceiver接收请求处理数据 1、DataXceiver线程的run方法 DataXceiver继承了Receiver...

    0.1 1961 0 1
  • Resize,w 360,h 240
    hdfs写之DataStreamer守护线程<三>

    一、流程图 client和namenode之前的rpc协议都是ClientProtocol。 locateFollowingBlock主要是通过...

    0.1 1174 0 2
  • Resize,w 360,h 240
    hdfs写之写数据<二>

    一、写数据流程图 该流程主要是客户端开始写数据，然后把数据切分多个chunk，多个chunk组成一个packet，发送到queue中，等待dat...

    0.1 877 2 1
  • Resize,w 360,h 240
    hdfs写之打开文件流<一>

    一、客户端创建写文件的流程图 namenode主要创建客户端RPC请求的准写的文件，namenode会把文件名保存到namespace中，然后返...

    0.1 757 0 2
  • Resize,w 360,h 240
    hdfs读之总结<四>

    一、hdfs读取流程图 假设block副本个数3个 客户端发起请求到namenode节点，要求namenode告诉客户端读取的block位置在哪...

    0.1 302 0 1
  • hdfs读之socket通讯解析<三>

    一、通讯流程图 二、Sender客户端解析 1、RemoteBlockReader2.newBlockReader()解析 根据block信息向...

    0.3 1058 0 3
  • Resize,w 360,h 240
    hdfs读之read读取解析<二>

    一、读取block数据方法流转 传输数据是通过scoket建立的，Sender和Receiver，这两个方法都继承了父类DataTransfer...

    0.1 652 0 1
暂无个人介绍