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

Region.getCoprocessorHost介绍

暂无

代码示例

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

private List<BulkLoadObserver> getBulkLoadObservers() {
 List<BulkLoadObserver> coprocessorList =
      this.env.getRegion().getCoprocessorHost().findCoprocessors(BulkLoadObserver.class);
 return coprocessorList;
}

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

quota.addMutation(append);
Result r = null;
if (region.getCoprocessorHost() != null) {
 r = region.getCoprocessorHost().preAppend(append);
  endNonceOperation(m, nonceGroup, success);
 if (region.getCoprocessorHost() != null) {
  region.getCoprocessorHost().postAppend(append, r);

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

@Override
 public void leaseExpired() {
  RegionScannerHolder rsh = scanners.remove(this.scannerName);
  if (rsh != null) {
   RegionScanner s = rsh.s;
   LOG.info("Scanner " + this.scannerName + " lease expired on region "
    + s.getRegionInfo().getRegionNameAsString());
   try {
    Region region = regionServer.getRegion(s.getRegionInfo().getRegionName());
    if (region != null && region.getCoprocessorHost() != null) {
     region.getCoprocessorHost().preScannerClose(s);
    }
    s.close();
    if (region != null && region.getCoprocessorHost() != null) {
     region.getCoprocessorHost().postScannerClose(s);
    }
   } catch (IOException e) {
    LOG.error("Closing scanner for "
     + s.getRegionInfo().getRegionNameAsString(), e);
   }
  } else {
   LOG.warn("Scanner " + this.scannerName + " lease expired, but no related" +
    " scanner found, hence no chance to close that related scanner!");
  }
 }
}

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

quota.addMutation(increment);
Result r = null;
if (region.getCoprocessorHost() != null) {
 r = region.getCoprocessorHost().preIncrement(increment);
  endNonceOperation(mutation, nonceGroup, success);
 if (region.getCoprocessorHost() != null) {
  r = region.getCoprocessorHost().postIncrement(increment, r);

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

public String[] getRegionServerCoprocessors() {
 TreeSet<String> coprocessors = new TreeSet<String>();
 try {
  coprocessors.addAll(getWAL(null).getCoprocessorHost().getCoprocessors());
 } catch (IOException exception) {
  LOG.warn("Exception attempting to fetch wal coprocessor information for the common wal; " +
    "skipping.");
  LOG.debug("Exception details for failure to fetch wal coprocessor information.", exception);
 }
 Collection<Region> regions = getOnlineRegionsLocalContext();
 for (Region region: regions) {
  coprocessors.addAll(region.getCoprocessorHost().getCoprocessors());
  try {
   coprocessors.addAll(getWAL(region.getRegionInfo()).getCoprocessorHost().getCoprocessors());
  } catch (IOException exception) {
   LOG.warn("Exception attempting to fetch wal coprocessor information for region " + region +
     "; skipping.");
   LOG.debug("Exception details for failure to fetch wal coprocessor information.", exception);
  }
 }
 return coprocessors.toArray(new String[coprocessors.size()]);
}

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

if (region.getCoprocessorHost() != null) {
 bypass = region.getCoprocessorHost().preBulkLoadHFile(familyPaths);
 loaded = region.bulkLoadHFiles(familyPaths, request.getAssignSeqNum(), null);
if (region.getCoprocessorHost() != null) {
 loaded = region.getCoprocessorHost().postBulkLoadHFile(familyPaths, loaded);

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

if ((actualRegion != null) && (actualRegion.getCoprocessorHost() != null)) {
 try {
  actualRegion.getCoprocessorHost().preClose(false);
 } catch (IOException exp) {
  LOG.warn("Unable to close region: the coprocessor launched an error ", exp);

代码示例来源：origin: locationtech/geowave

scan.setAuthorizations(new Authorizations(authorizations));
env.getRegion().getCoprocessorHost().preScannerOpen(scan);
try (InternalScanner scanner = env.getRegion().getScanner(scan)) {
 final List<Cell> results = new ArrayList<Cell>();

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

RegionSpecifier.Builder regionSpecifier = RegionSpecifier.newBuilder();
for (Region region : regions) {
 if (region.getCoprocessorHost() != null) {
  Set<String> regionCoprocessors = region.getCoprocessorHost().getCoprocessors();
  Iterator<String> iterator = regionCoprocessors.iterator();
  while (iterator.hasNext()) {

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

if (region.getCoprocessorHost() != null) {
 scanner = region.getCoprocessorHost().preScannerOpen(scan);
if (region.getCoprocessorHost() != null) {
 scanner = region.getCoprocessorHost().postScannerOpen(scan, scanner);
 if (region != null && region.getCoprocessorHost() != null) {
  Boolean bypass = region.getCoprocessorHost().preScannerNext(
   scanner, results, rows);
  if (!results.isEmpty()) {
  if (region != null && region.getCoprocessorHost() != null) {
   region.getCoprocessorHost().postScannerNext(scanner, results, rows, true);
ttl = 0;
moreResults = false;
if (region != null && region.getCoprocessorHost() != null) {
 if (region.getCoprocessorHost().preScannerClose(scanner)) {
  return builder.build(); // bypass
 scanner.close();
 regionServer.leases.cancelLease(scannerName);
 if (region != null && region.getCoprocessorHost() != null) {
  region.getCoprocessorHost().postScannerClose(scanner);

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

if (region.getCoprocessorHost() != null) {
 try {
  bypass = region.getCoprocessorHost().preBulkLoadHFile(familyPaths);
 } catch (IOException e) {
  ResponseConverter.setControllerException(controller, e);
if (region.getCoprocessorHost() != null) {
 try {
  loaded = region.getCoprocessorHost().postBulkLoadHFile(familyPaths, loaded);
 } catch (IOException e) {
  ResponseConverter.setControllerException(controller, e);

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

ByteArrayComparable comparator =
 ProtobufUtil.toComparator(condition.getComparator());
if (region.getCoprocessorHost() != null) {
 processed = region.getCoprocessorHost().preCheckAndPut(
  row, family, qualifier, compareOp, comparator, put);
 boolean result = region.checkAndMutate(row, family,
  qualifier, compareOp, comparator, put, true);
 if (region.getCoprocessorHost() != null) {
  result = region.getCoprocessorHost().postCheckAndPut(row, family,
   qualifier, compareOp, comparator, put, result);
ByteArrayComparable comparator =
 ProtobufUtil.toComparator(condition.getComparator());
if (region.getCoprocessorHost() != null) {
 processed = region.getCoprocessorHost().preCheckAndDelete(
  row, family, qualifier, compareOp, comparator, delete);
 boolean result = region.checkAndMutate(row, family,
  qualifier, compareOp, comparator, delete, true);
 if (region.getCoprocessorHost() != null) {
  result = region.getCoprocessorHost().postCheckAndDelete(row, family,
   qualifier, compareOp, comparator, delete, result);

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

} else {
 Get clientGet = ProtobufUtil.toGet(get);
 if (get.getExistenceOnly() && region.getCoprocessorHost() != null) {
  existence = region.getCoprocessorHost().preExists(clientGet);
  if (get.getExistenceOnly()) {
   boolean exists = r.getExists();
   if (region.getCoprocessorHost() != null) {
    exists = region.getCoprocessorHost().postExists(clientGet, exists);

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

if ((region  != null) && (region .getCoprocessorHost() != null)) {
 region.getCoprocessorHost().preClose(false);

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

if (onlineRegion != null) {
 if (onlineRegion.getCoprocessorHost() != null) {
  onlineRegion.getCoprocessorHost().preOpen();

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

RegionCoprocessorHost coprocessorHost =
  ServerRegionReplicaUtil.isDefaultReplica(region.getRegionInfo())
   ? region.getCoprocessorHost()