Java 类org.apache.hadoop.hbase.catalog.RootLocationEditor 实例源码

项目：LCIndex-HBase-0.94.16 文件：HRegionServer.java

@Override
public void postOpenDeployTasks(final HRegion r, final CatalogTracker ct, final boolean daughter)
    throws KeeperException, IOException {
  checkOpen();
  LOG.info("Post open deploy tasks for region=" + r.getRegionNameAsString() + ", daughter="
      + daughter);
  // Do checks to see if we need to compact (references or too many files)
  for (Store s : r.getStores().values()) {
    if (s.hasReferences() || s.needsCompaction()) {
      getCompactionRequester().requestCompaction(r, s, "Opening Region", null);
    }
  }
  // Update ZK, ROOT or META
  if (r.getRegionInfo().isRootRegion()) {
    RootLocationEditor.setRootLocation(getZooKeeper(), this.serverNameFromMasterPOV);
  } else if (r.getRegionInfo().isMetaRegion()) {
    MetaEditor.updateMetaLocation(ct, r.getRegionInfo(), this.serverNameFromMasterPOV);
  } else {
    if (daughter) {
      // If daughter of a split, update whole row, not just location.
      MetaEditor.addDaughter(ct, r.getRegionInfo(), this.serverNameFromMasterPOV);
    } else {
      MetaEditor.updateRegionLocation(ct, r.getRegionInfo(), this.serverNameFromMasterPOV);
    }
  }
  LOG.info("Done with post open deploy task for region=" + r.getRegionNameAsString()
      + ", daughter=" + daughter);

}

项目：IRIndex 文件：HRegionServer.java

@Override
public void postOpenDeployTasks(final HRegion r, final CatalogTracker ct,
    final boolean daughter)
throws KeeperException, IOException {
  checkOpen();
  LOG.info("Post open deploy tasks for region=" + r.getRegionNameAsString() +
    ", daughter=" + daughter);
  // Do checks to see if we need to compact (references or too many files)
  for (Store s : r.getStores().values()) {
    if (s.hasReferences() || s.needsCompaction()) {
      getCompactionRequester().requestCompaction(r, s, "Opening Region", null);
    }
  }
  // Update ZK, ROOT or META
  if (r.getRegionInfo().isRootRegion()) {
    RootLocationEditor.setRootLocation(getZooKeeper(),
     this.serverNameFromMasterPOV);
  } else if (r.getRegionInfo().isMetaRegion()) {
    MetaEditor.updateMetaLocation(ct, r.getRegionInfo(),
      this.serverNameFromMasterPOV);
  } else {
    if (daughter) {
      // If daughter of a split, update whole row, not just location.
      MetaEditor.addDaughter(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    } else {
      MetaEditor.updateRegionLocation(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    }
  }
  LOG.info("Done with post open deploy task for region=" +
    r.getRegionNameAsString() + ", daughter=" + daughter);

}

项目：RStore 文件：HRegionServer.java

@Override
public void postOpenDeployTasks(final HRegion r, final CatalogTracker ct,
    final boolean daughter)
throws KeeperException, IOException {
  LOG.info("Post open deploy tasks for region=" + r.getRegionNameAsString() +
    ", daughter=" + daughter);
  // Do checks to see if we need to compact (references or too many files)
  for (Store s : r.getStores().values()) {
    if (s.hasReferences() || s.needsCompaction()) {
      getCompactionRequester().requestCompaction(r, s, "Opening Region");
    }
  }
  // Update ZK, ROOT or META
  if (r.getRegionInfo().isRootRegion()) {
    RootLocationEditor.setRootLocation(getZooKeeper(),
     this.serverNameFromMasterPOV);
  } else if (r.getRegionInfo().isMetaRegion()) {
    MetaEditor.updateMetaLocation(ct, r.getRegionInfo(),
      this.serverNameFromMasterPOV);
  } else {
    if (daughter) {
      // If daughter of a split, update whole row, not just location.
      MetaEditor.addDaughter(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    } else {
      MetaEditor.updateRegionLocation(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    }
  }
  LOG.info("Done with post open deploy task for region=" +
    r.getRegionNameAsString() + ", daughter=" + daughter);

}

项目：HBase-Research 文件：HRegionServer.java

@Override
public void postOpenDeployTasks(final HRegion r, final CatalogTracker ct,
    final boolean daughter)
throws KeeperException, IOException {
  checkOpen();
  LOG.info("Post open deploy tasks for region=" + r.getRegionNameAsString() +
    ", daughter=" + daughter);
  // Do checks to see if we need to compact (references or too many files)
  for (Store s : r.getStores().values()) {
    if (s.hasReferences() || s.needsCompaction()) {
      getCompactionRequester().requestCompaction(r, s, "Opening Region", null);
    }
  }
  // Update ZK, ROOT or META
  if (r.getRegionInfo().isRootRegion()) {
    RootLocationEditor.setRootLocation(getZooKeeper(),
     this.serverNameFromMasterPOV);
  } else if (r.getRegionInfo().isMetaRegion()) {
    MetaEditor.updateMetaLocation(ct, r.getRegionInfo(),
      this.serverNameFromMasterPOV);
  } else {
    if (daughter) {
      // If daughter of a split, update whole row, not just location.
      MetaEditor.addDaughter(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    } else {
      MetaEditor.updateRegionLocation(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    }
  }
  LOG.info("Done with post open deploy task for region=" +
    r.getRegionNameAsString() + ", daughter=" + daughter);

}

项目：hbase-0.94.8-qod 文件：HRegionServer.java

@Override
public void postOpenDeployTasks(final HRegion r, final CatalogTracker ct,
    final boolean daughter)
throws KeeperException, IOException {
  checkOpen();
  LOG.info("Post open deploy tasks for region=" + r.getRegionNameAsString() +
    ", daughter=" + daughter);
  // Do checks to see if we need to compact (references or too many files)
  for (Store s : r.getStores().values()) {
    if (s.hasReferences() || s.needsCompaction()) {
      getCompactionRequester().requestCompaction(r, s, "Opening Region", null);
    }
  }
  // Update ZK, ROOT or META
  if (r.getRegionInfo().isRootRegion()) {
    RootLocationEditor.setRootLocation(getZooKeeper(),
     this.serverNameFromMasterPOV);
  } else if (r.getRegionInfo().isMetaRegion()) {
    MetaEditor.updateMetaLocation(ct, r.getRegionInfo(),
      this.serverNameFromMasterPOV);
  } else {
    if (daughter) {
      // If daughter of a split, update whole row, not just location.
      MetaEditor.addDaughter(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    } else {
      MetaEditor.updateRegionLocation(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    }
  }
  LOG.info("Done with post open deploy task for region=" +
    r.getRegionNameAsString() + ", daughter=" + daughter);

}

项目：hbase-0.94.8-qod 文件：HRegionServer.java

@Override
public void postOpenDeployTasks(final HRegion r, final CatalogTracker ct,
    final boolean daughter)
throws KeeperException, IOException {
  checkOpen();
  LOG.info("Post open deploy tasks for region=" + r.getRegionNameAsString() +
    ", daughter=" + daughter);
  // Do checks to see if we need to compact (references or too many files)
  for (Store s : r.getStores().values()) {
    if (s.hasReferences() || s.needsCompaction()) {
      getCompactionRequester().requestCompaction(r, s, "Opening Region", null);
    }
  }
  // Update ZK, ROOT or META
  if (r.getRegionInfo().isRootRegion()) {
    RootLocationEditor.setRootLocation(getZooKeeper(),
     this.serverNameFromMasterPOV);
  } else if (r.getRegionInfo().isMetaRegion()) {
    MetaEditor.updateMetaLocation(ct, r.getRegionInfo(),
      this.serverNameFromMasterPOV);
  } else {
    if (daughter) {
      // If daughter of a split, update whole row, not just location.
      MetaEditor.addDaughter(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    } else {
      MetaEditor.updateRegionLocation(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    }
  }
  LOG.info("Done with post open deploy task for region=" +
    r.getRegionNameAsString() + ", daughter=" + daughter);

}

项目：hindex 文件：HRegionServer.java

@Override
public void postOpenDeployTasks(final HRegion r, final CatalogTracker ct,
    final boolean daughter)
throws KeeperException, IOException {
  checkOpen();
  LOG.info("Post open deploy tasks for region=" + r.getRegionNameAsString() +
    ", daughter=" + daughter);
  // Do checks to see if we need to compact (references or too many files)
  for (Store s : r.getStores().values()) {
    if (s.hasReferences() || s.needsCompaction()) {
      getCompactionRequester().requestCompaction(r, s, "Opening Region", null);
    }
  }
  // Update ZK, ROOT or META
  if (r.getRegionInfo().isRootRegion()) {
    RootLocationEditor.setRootLocation(getZooKeeper(),
     this.serverNameFromMasterPOV);
  } else if (r.getRegionInfo().isMetaRegion()) {
    MetaEditor.updateMetaLocation(ct, r.getRegionInfo(),
      this.serverNameFromMasterPOV);
  } else {
    if (daughter) {
      // If daughter of a split, update whole row, not just location.
      MetaEditor.addDaughter(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    } else {
      MetaEditor.updateRegionLocation(ct, r.getRegionInfo(),
        this.serverNameFromMasterPOV);
    }
  }
  LOG.info("Done with post open deploy task for region=" +
    r.getRegionNameAsString() + ", daughter=" + daughter);

}

项目：LCIndex-HBase-0.94.16 文件：AssignmentManager.java

/**
 * Assigns the ROOT region.
 * <p>
 * Assumes that ROOT is currently closed and is not being actively served by
 * any RegionServer.
 * <p>
 * Forcibly unsets the current root region location in ZooKeeper and assigns
 * ROOT to a random RegionServer.
 * @throws KeeperException
 */
public void assignRoot() throws KeeperException {
  RootLocationEditor.deleteRootLocation(this.master.getZooKeeper());
  assign(HRegionInfo.ROOT_REGIONINFO, true);
}

项目：IRIndex 文件：AssignmentManager.java

/**
 * Assigns the ROOT region.
 * <p>
 * Assumes that ROOT is currently closed and is not being actively served by
 * any RegionServer.
 * <p>
 * Forcibly unsets the current root region location in ZooKeeper and assigns
 * ROOT to a random RegionServer.
 * @throws KeeperException
 */
public void assignRoot() throws KeeperException {
  RootLocationEditor.deleteRootLocation(this.master.getZooKeeper());
  assign(HRegionInfo.ROOT_REGIONINFO, true);
}

项目：RStore 文件：AssignmentManager.java

/**
 * Assigns the ROOT region.
 * <p>
 * Assumes that ROOT is currently closed and is not being actively served by
 * any RegionServer.
 * <p>
 * Forcibly unsets the current root region location in ZooKeeper and assigns
 * ROOT to a random RegionServer.
 * @throws KeeperException
 */
public void assignRoot() throws KeeperException {
  RootLocationEditor.deleteRootLocation(this.master.getZooKeeper());
  assign(HRegionInfo.ROOT_REGIONINFO, true);
}

项目：HBase-Research 文件：AssignmentManager.java

/**
 * Assigns the ROOT region.
 * <p>
 * Assumes that ROOT is currently closed and is not being actively served by
 * any RegionServer.
 * <p>
 * Forcibly unsets the current root region location in ZooKeeper and assigns
 * ROOT to a random RegionServer.
 * @throws KeeperException
 */
public void assignRoot() throws KeeperException {
  RootLocationEditor.deleteRootLocation(this.master.getZooKeeper());
  assign(HRegionInfo.ROOT_REGIONINFO, true);
}

项目：hbase-0.94.8-qod 文件：AssignmentManager.java

/**
 * Assigns the ROOT region.
 * <p>
 * Assumes that ROOT is currently closed and is not being actively served by
 * any RegionServer.
 * <p>
 * Forcibly unsets the current root region location in ZooKeeper and assigns
 * ROOT to a random RegionServer.
 * @throws KeeperException
 */
public void assignRoot() throws KeeperException {
  RootLocationEditor.deleteRootLocation(this.master.getZooKeeper());
  assign(HRegionInfo.ROOT_REGIONINFO, true);
}

项目：hbase-0.94.8-qod 文件：AssignmentManager.java

/**
 * Assigns the ROOT region.
 * <p>
 * Assumes that ROOT is currently closed and is not being actively served by
 * any RegionServer.
 * <p>
 * Forcibly unsets the current root region location in ZooKeeper and assigns
 * ROOT to a random RegionServer.
 * @throws KeeperException
 */
public void assignRoot() throws KeeperException {
  RootLocationEditor.deleteRootLocation(this.master.getZooKeeper());
  assign(HRegionInfo.ROOT_REGIONINFO, true);
}

项目：hindex 文件：AssignmentManager.java

/**
 * Assigns the ROOT region.
 * <p>
 * Assumes that ROOT is currently closed and is not being actively served by
 * any RegionServer.
 * <p>
 * Forcibly unsets the current root region location in ZooKeeper and assigns
 * ROOT to a random RegionServer.
 * @throws KeeperException
 */
public void assignRoot() throws KeeperException {
  RootLocationEditor.deleteRootLocation(this.master.getZooKeeper());
  assign(HRegionInfo.ROOT_REGIONINFO, true);
}