org.apache.hadoop.hbase.zookeeper.ZKAssign.getRegionName()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.6k)|赞(0)|评价(0)|浏览(181)

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

ZKAssign.getRegionName介绍

[英]Gets the region name from the full path node name of an unassigned node.
[中]从未分配节点的完整路径节点名称中获取区域名称。

代码示例

代码示例来源:origin: harbby/presto-connectors

  1. @Override
  2. public void nodeDeleted(final String path) {
  3. if (path.startsWith(watcher.assignmentZNode)) {
  4. final String regionName = ZKAssign.getRegionName(watcher, path);
  5. zkEventWorkersSubmit(new RegionRunnable() {
  6. @Override

代码示例来源:origin: harbby/presto-connectors

  1. final String regionName = ZKAssign.getRegionName(watcher, path);

代码示例来源:origin: co.cask.hbase/hbase

  1. @Override
  2. public void nodeDeleted(final String path) {
  3. if (path.startsWith(this.watcher.assignmentZNode)) {
  4. String regionName = ZKAssign.getRegionName(this.master.getZooKeeper(), path);
  5. RegionState rs = this.regionsInTransition.get(regionName);
  6. if (rs != null) {
  7. HRegionInfo regionInfo = rs.getRegion();
  8. if (rs.isSplit()) {
  9. LOG.debug("Ephemeral node deleted, regionserver crashed?, offlining the region"
  10. + rs.getRegion() + " clearing from RIT;");
  11. regionOffline(rs.getRegion());
  12. } else if (rs.isSplitting()) {
  13. LOG.debug("Ephemeral node deleted. Found in SPLITTING state. " + "Removing from RIT "
  14. + rs.getRegion());
  15. synchronized(this.regionsInTransition) {
  16. this.regionsInTransition.remove(regionName);
  17. }
  18. } else {
  19. LOG.debug("The znode of region " + regionInfo.getRegionNameAsString()
  20. + " has been deleted.");
  21. if (rs.isOpened()) {
  22. makeRegionOnline(rs, regionInfo);
  23. }
  24. }
  25. }
  26. }
  27. }

相关文章