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

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

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

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

org.apache.hadoop.hdfs.server.datanode.RaidBlockSender.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)}. @return total bytes reads, including crc.

      DatanodeInfo[] nodes = new DatanodeInfo[]{datanode};
      DataTransferProtocol.Sender.opWriteBlock(
        out, block.getBlock(), 1,
        DataTransferProtocol.BlockConstructionStage.PIPELINE_SETUP_CREATE,
        0, blockSize, 0, "", null, nodes, block.getBlockToken());
      blockSender.sendBlock(out, baseStream);


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

View Full Code Here

        
        DatanodeInfo[] nodes = new DatanodeInfo[]{datanode};
        new Sender(out).writeBlock(block.getBlock(), block.getBlockToken(), "",
            nodes, null, BlockConstructionStage.PIPELINE_SETUP_CREATE,
            1, 0L, blockSize, 0L, DataChecksum.newDataChecksum(metadataIn));
        blockSender.sendBlock(out, baseStream);
        
        LOG.info("Sent block " + block.getBlock() + " to " + datanode.name);
      } finally {
        out.close();
      }

View Full Code Here

        
        DatanodeInfo[] nodes = new DatanodeInfo[]{datanode};
        new Sender(out).writeBlock(block.getBlock(), block.getBlockToken(), "",
            nodes, null, BlockConstructionStage.PIPELINE_SETUP_CREATE,
            1, 0L, blockSize, 0L, DataChecksum.newDataChecksum(metadataIn));
        blockSender.sendBlock(out, baseStream);
        
        LOG.info("Sent block " + block.getBlock() + " to " + datanode.getName());
      } finally {
        out.close();
      }

View Full Code Here

        
        DatanodeInfo[] nodes = new DatanodeInfo[]{datanode};
        new Sender(out).writeBlock(block.getBlock(), block.getBlockToken(), "",
            nodes, null, BlockConstructionStage.PIPELINE_SETUP_CREATE,
            1, 0L, blockSize, 0L, DataChecksum.newDataChecksum(metadataIn));
        blockSender.sendBlock(out, baseStream);
        
        LOG.info("Sent block " + block.getBlock() + " to " + datanode.name);
      } finally {
        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.