org.apache.hadoop.hdfs.protocol.Block.set()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(3.9k)|赞(0)|评价(0)|浏览(219)

本文整理了Java中org.apache.hadoop.hdfs.protocol.Block.set()方法的一些代码示例,展示了Block.set()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Block.set()方法的具体详情如下:
包路径:org.apache.hadoop.hdfs.protocol.Block
类名称:Block
方法名:set

Block.set介绍

暂无

代码示例

代码示例来源:origin: ch.cern.hadoop/hadoop-hdfs

public Block(final long blkid, final long len, final long generationStamp) {
 set(blkid, len, generationStamp);
}

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

tmp.set(block.getBlockId(), block.getNumBytes(), GenerationStamp.WILDCARD_STAMP);
if (ongoingRecovery.get(tmp) != null) {
 String msg = "Block " + block + " is already being recovered, " +

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

public Block(final long blkid, final long len, final long generationStamp) {
 set(blkid, len, generationStamp);
}

代码示例来源:origin: com.facebook.hadoop/hadoop-core

tmp.set(block.getBlockId(), block.getNumBytes(), GenerationStamp.WILDCARD_STAMP);
if (ongoingRecovery.get(tmp) != null) {
 String msg = "Block " + block + " is already being recovered, " +

代码示例来源:origin: org.apache.hadoop/hadoop-hdfs-client

public Block(final long blkid, final long len, final long generationStamp) {
 set(blkid, len, generationStamp);
}

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

public Block(final long blkid, final long len, final long generationStamp) {
 set(blkid, len, generationStamp);
}

代码示例来源:origin: com.facebook.hadoop/hadoop-core

public Block(final long blkid, final long len, final long generationStamp) {
 set(blkid, len, generationStamp);
}

代码示例来源:origin: com.facebook.hadoop/hadoop-core

private static Block[] readBlocks(
   DataInputStream in,
   int logVersion) throws IOException {
  int numBlocks = in.readInt();
  Block[] blocks = new Block[numBlocks];
  for (int i = 0; i < numBlocks; i++) {
   Block blk = new Block();
   if (logVersion <= -14) {
    blk.readFields(in);
   } else {
    BlockTwo oldblk = new BlockTwo();
    oldblk.readFields(in);
    blk.set(oldblk.blkid, oldblk.len,
        Block.GRANDFATHER_GENERATION_STAMP);
   }
   blocks[i] = blk;
  }
  return blocks;
 }
}

代码示例来源:origin: org.apache.hadoop/hadoop-hdfs-test

b.set(b.getBlockId(), tempLen, b.getGenerationStamp());
if(LOG.isDebugEnabled()) {
 LOG.debug("Block " + b.getBlockName() + " after\t " + "Size " +

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

blocks[j] = new Block();
if (-14 < imgVersion) {
 blocks[j].set(in.readLong(), in.readLong(), 
        Block.GRANDFATHER_GENERATION_STAMP);
} else {

代码示例来源:origin: com.facebook.hadoop/hadoop-core

} else {
 lastblock.set(lastblock.getBlockId(), newlength, newgenerationstamp);
 final BlockInfo newblockinfo = blocksMap.addINode(lastblock, pendingFile);

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

iblk.set(newReport.getBlockId(i), newReport.getBlockLen(i), 
     newReport.getBlockGenStamp(i));
BlockInfo storedBlock = blocksMap.getStoredBlock(iblk);

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

lastblock.set(lastblock.getBlockId(), newlength, newgenerationstamp);
final BlockInfo newblockinfo = blocksMap.addINode(lastblock, pendingFile);

代码示例来源:origin: com.facebook.hadoop/hadoop-core

Block iblk = new Block(); // a fixed new'ed block to be reused with index i
for (int i = 0; i < newReport.getNumberOfBlocks(); ++i) {
 iblk.set(newReport.getBlockId(i), newReport.getBlockLen(i),
  newReport.getBlockGenStamp(i));
 if (!addStoredBlockInternal(iblk, node, null, true)

代码示例来源:origin: ch.cern.hadoop/hadoop-hdfs

b.set(b.getBlockId(), tempLen, b.getGenerationStamp());
if(LOG.isDebugEnabled()) {
 LOG.debug("Block " + b.getBlockName() + " after\t " + "Size " +

代码示例来源:origin: com.facebook.hadoop/hadoop-core

Block oblk = new Block(); // for fixing genstamps
for (int i = 0; i < newReport.getNumberOfBlocks(); ++i) {
 iblk.set(newReport.getBlockId(i), newReport.getBlockLen(i), 
      newReport.getBlockGenStamp(i));
 BlockInfo storedBlock = blocksMap.getStoredBlock(iblk);
  oblk.set(newReport.getBlockId(i), newReport.getBlockLen(i),
       GenerationStamp.WILDCARD_STAMP);
  storedBlock = blocksMap.getStoredBlock(oblk);

代码示例来源:origin: com.facebook.hadoop/hadoop-core

block.set(blocksBeingWritten.getBlockId(i), 
  blocksBeingWritten.getBlockLen(i), 
  blocksBeingWritten.getBlockGenStamp(i));

相关文章