Java AddBlockOp类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.AddBlockOp类的典型用法代码示例。如果您正苦于以下问题：Java AddBlockOp类的具体用法？Java AddBlockOp怎么用？Java AddBlockOp使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

AddBlockOp类属于org.apache.hadoop.hdfs.server.namenode.FSEditLogOp包，在下文中一共展示了AddBlockOp类的5个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: addNewBlock

import org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.AddBlockOp; //导入依赖的package包/类
/**
 * Add a new block into the given INodeFile
 */
private void addNewBlock(FSDirectory fsDir, AddBlockOp op, INodeFile file)
    throws IOException {
  BlockInfoContiguous[] oldBlocks = file.getBlocks();
  Block pBlock = op.getPenultimateBlock();
  Block newBlock= op.getLastBlock();
  
  if (pBlock != null) { // the penultimate block is not null
    Preconditions.checkState(oldBlocks != null && oldBlocks.length > 0);
    // compare pBlock with the last block of oldBlocks
    Block oldLastBlock = oldBlocks[oldBlocks.length - 1];
    if (oldLastBlock.getBlockId() != pBlock.getBlockId()
        || oldLastBlock.getGenerationStamp() != pBlock.getGenerationStamp()) {
      throw new IOException(
          "Mismatched block IDs or generation stamps for the old last block of file "
              + op.getPath() + ", the old last block is " + oldLastBlock
              + ", and the block read from editlog is " + pBlock);
    }
    
    oldLastBlock.setNumBytes(pBlock.getNumBytes());
    if (oldLastBlock instanceof BlockInfoContiguousUnderConstruction) {
      fsNamesys.getBlockManager().forceCompleteBlock(file,
          (BlockInfoContiguousUnderConstruction) oldLastBlock);
      fsNamesys.getBlockManager().processQueuedMessagesForBlock(pBlock);
    }
  } else { // the penultimate block is null
    Preconditions.checkState(oldBlocks == null || oldBlocks.length == 0);
  }
  // add the new block
  BlockInfoContiguous newBI = new BlockInfoContiguousUnderConstruction(
        newBlock, file.getBlockReplication());
  fsNamesys.getBlockManager().addBlockCollection(newBI, file);
  file.addBlock(newBI);
  fsNamesys.getBlockManager().processQueuedMessagesForBlock(newBlock);
}

开发者ID:naver，项目名称:hadoop，代码行数:38，代码来源:FSEditLogLoader.java

示例2: logAddBlock

import org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.AddBlockOp; //导入依赖的package包/类
public void logAddBlock(String path, INodeFile file) {
  Preconditions.checkArgument(file.isUnderConstruction());
  BlockInfoContiguous[] blocks = file.getBlocks();
  Preconditions.checkState(blocks != null && blocks.length > 0);
  BlockInfoContiguous pBlock = blocks.length > 1 ? blocks[blocks.length - 2] : null;
  BlockInfoContiguous lastBlock = blocks[blocks.length - 1];
  AddBlockOp op = AddBlockOp.getInstance(cache.get()).setPath(path)
      .setPenultimateBlock(pBlock).setLastBlock(lastBlock);
  logEdit(op);
}

开发者ID:naver，项目名称:hadoop，代码行数:11，代码来源:FSEditLog.java

示例3: logAddBlock

import org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.AddBlockOp; //导入依赖的package包/类
public void logAddBlock(String path, INodeFile file) {
  Preconditions.checkArgument(file.isUnderConstruction());
  BlockInfo[] blocks = file.getBlocks();
  Preconditions.checkState(blocks != null && blocks.length > 0);
  BlockInfo pBlock = blocks.length > 1 ? blocks[blocks.length - 2] : null;
  BlockInfo lastBlock = blocks[blocks.length - 1];
  AddBlockOp op = AddBlockOp.getInstance(cache.get()).setPath(path)
      .setPenultimateBlock(pBlock).setLastBlock(lastBlock);
  logEdit(op);
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:11，代码来源:FSEditLog.java

示例4: addNewBlock

import org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.AddBlockOp; //导入依赖的package包/类
/**
 * Add a new block into the given INodeFile
 */
private void addNewBlock(FSDirectory fsDir, AddBlockOp op, INodeFile file)
    throws IOException {
  BlockInfo[] oldBlocks = file.getBlocks();
  Block pBlock = op.getPenultimateBlock();
  Block newBlock= op.getLastBlock();
  
  if (pBlock != null) { // the penultimate block is not null
    Preconditions.checkState(oldBlocks != null && oldBlocks.length > 0);
    // compare pBlock with the last block of oldBlocks
    Block oldLastBlock = oldBlocks[oldBlocks.length - 1];
    if (oldLastBlock.getBlockId() != pBlock.getBlockId()
        || oldLastBlock.getGenerationStamp() != pBlock.getGenerationStamp()) {
      throw new IOException(
          "Mismatched block IDs or generation stamps for the old last block of file "
              + op.getPath() + ", the old last block is " + oldLastBlock
              + ", and the block read from editlog is " + pBlock);
    }
    
    oldLastBlock.setNumBytes(pBlock.getNumBytes());
    if (oldLastBlock instanceof BlockInfoUnderConstruction) {
      fsNamesys.getBlockManager().forceCompleteBlock(file,
          (BlockInfoUnderConstruction) oldLastBlock);
      fsNamesys.getBlockManager().processQueuedMessagesForBlock(pBlock);
    }
  } else { // the penultimate block is null
    Preconditions.checkState(oldBlocks == null || oldBlocks.length == 0);
  }
  // add the new block
  BlockInfo newBI = new BlockInfoUnderConstruction(
        newBlock, file.getBlockReplication());
  fsNamesys.getBlockManager().addBlockCollection(newBI, file);
  file.addBlock(newBI);
  fsNamesys.getBlockManager().processQueuedMessagesForBlock(newBlock);
}

开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:38，代码来源:FSEditLogLoader.java

示例5: addNewBlock

import org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.AddBlockOp; //导入依赖的package包/类
/**
 * Add a new block into the given INodeFile
 */
private void addNewBlock(AddBlockOp op, INodeFile file,
    ErasureCodingPolicy ecPolicy) throws IOException {
  BlockInfo[] oldBlocks = file.getBlocks();
  Block pBlock = op.getPenultimateBlock();
  Block newBlock= op.getLastBlock();
  
  if (pBlock != null) { // the penultimate block is not null
    assert oldBlocks != null && oldBlocks.length > 0;
    // compare pBlock with the last block of oldBlocks
    BlockInfo oldLastBlock = oldBlocks[oldBlocks.length - 1];
    if (oldLastBlock.getBlockId() != pBlock.getBlockId()
        || oldLastBlock.getGenerationStamp() != pBlock.getGenerationStamp()) {
      throw new IOException(
          "Mismatched block IDs or generation stamps for the old last block of file "
              + op.getPath() + ", the old last block is " + oldLastBlock
              + ", and the block read from editlog is " + pBlock);
    }
    
    oldLastBlock.setNumBytes(pBlock.getNumBytes());
    if (!oldLastBlock.isComplete()) {
      fsNamesys.getBlockManager().forceCompleteBlock(oldLastBlock);
      fsNamesys.getBlockManager().processQueuedMessagesForBlock(pBlock);
    }
  } else { // the penultimate block is null
    Preconditions.checkState(oldBlocks == null || oldBlocks.length == 0);
  }
  // add the new block
  final BlockInfo newBlockInfo;
  boolean isStriped = ecPolicy != null;
  if (isStriped) {
    newBlockInfo = new BlockInfoStriped(newBlock, ecPolicy);
  } else {
    newBlockInfo = new BlockInfoContiguous(newBlock,
        file.getPreferredBlockReplication());
  }
  newBlockInfo.convertToBlockUnderConstruction(
      BlockUCState.UNDER_CONSTRUCTION, null);
  fsNamesys.getBlockManager().addBlockCollectionWithCheck(newBlockInfo, file);
  file.addBlock(newBlockInfo);
  fsNamesys.getBlockManager().processQueuedMessagesForBlock(newBlock);
}

开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:45，代码来源:FSEditLogLoader.java

注：本文中的org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.AddBlockOp类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。