Examples of org.apache.hadoop.hdfs.server.datanode.BlockSender.sendBlock()

Package org.apache.hadoop.hdfs.server.datanode

Class org.apache.hadoop.hdfs.server.datanode.BlockSender

Examples of org.apache.hadoop.hdfs.server.datanode.BlockSender.sendBlock()

org.apache.hadoop.hdfs.server.datanode.BlockSender.sendBlock()
sendBlock() is used to read block and its metadata and stream the data to either a client or to another datanode. @param out stream to which the block is written to @param baseStream optional. if non-null, out is assumed to be a wrapper over this stream. This enables optimizations for sending the data, e.g. {@link SocketOutputStream#transferToFully(FileChannel,long,int)}. @param throttler for sending data. @return total bytes reads, including crc.

      DatanodeInfo srcNode = new DatanodeInfo();
      srcNode.write(out); // Write src node DatanodeInfo
      // write targets
      out.writeInt(0); // num targets
      // send data & checksum
      blockSender.sendBlock(out, baseStream, null, progress);


      LOG.info("Sent block " + block + " to " + datanode);
    } finally {
      sock.close();
      out.close();

View Full Code Here

          dataTransferVersion, DataTransferProtocol.OP_WRITE_BLOCK));
      header.set(namespaceId, block.getBlockId(), block.getGenerationStamp(),
          0, false, true, new DatanodeInfo(), 0, null, "");
      header.writeVersionAndOpCode(out);
      header.write(out);
      blockSender.sendBlock(out, baseStream, null, progress);


      LOG.info("Sent block " + block + " to " + datanode);
    } finally {
      sock.close();
      out.close();

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.