Java 类org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.Coprocessor 实例源码

项目：ditb 文件：ServerLoad.java

/**
 * Return the RegionServer-level coprocessors
 * @return string array of loaded RegionServer-level coprocessors
 */
public String[] getRegionServerCoprocessors() {
  List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList();
  String [] ret = new String[list.size()];
  int i = 0;
  for (Coprocessor elem : list) {
    ret[i++] = elem.getName();
  }

  return ret;
}

项目：ditb 文件：ServerLoad.java

/**
 * Return the RegionServer-level and Region-level coprocessors
 * @return string array of loaded RegionServer-level and
 *         Region-level coprocessors
 */
public String[] getRsCoprocessors() {
  // Need a set to remove duplicates, but since generated Coprocessor class
  // is not Comparable, make it a Set<String> instead of Set<Coprocessor>
  TreeSet<String> coprocessSet = new TreeSet<String>();
  for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) {
    coprocessSet.add(coprocessor.getName());
  }
  return coprocessSet.toArray(new String[coprocessSet.size()]);
}

项目：pbase 文件：ServerLoad.java

/**
 * Return the RegionServer-level coprocessors
 * @return string array of loaded RegionServer-level coprocessors
 */
public String[] getRegionServerCoprocessors() {
  List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList();
  String [] ret = new String[list.size()];
  int i = 0;
  for (Coprocessor elem : list) {
    ret[i++] = elem.getName();
  }

  return ret;
}

项目：pbase 文件：ServerLoad.java

/**
 * Return the RegionServer-level and Region-level coprocessors
 * @return string array of loaded RegionServer-level and
 *         Region-level coprocessors
 */
public String[] getRsCoprocessors() {
  // Need a set to remove duplicates, but since generated Coprocessor class
  // is not Comparable, make it a Set<String> instead of Set<Coprocessor>
  TreeSet<String> coprocessSet = new TreeSet<String>();
  for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) {
    coprocessSet.add(coprocessor.getName());
  }
  return coprocessSet.toArray(new String[coprocessSet.size()]);
}

项目：HIndex 文件：HRegionServer.java

ClusterStatusProtos.ServerLoad buildServerLoad(long reportStartTime, long reportEndTime) {
  // We're getting the MetricsRegionServerWrapper here because the wrapper computes requests
  // per second, and other metrics  As long as metrics are part of ServerLoad it's best to use
  // the wrapper to compute those numbers in one place.
  // In the long term most of these should be moved off of ServerLoad and the heart beat.
  // Instead they should be stored in an HBase table so that external visibility into HBase is
  // improved; Additionally the load balancer will be able to take advantage of a more complete
  // history.
  MetricsRegionServerWrapper regionServerWrapper = this.metricsRegionServer.getRegionServerWrapper();
  Collection<HRegion> regions = getOnlineRegionsLocalContext();
  MemoryUsage memory =
    ManagementFactory.getMemoryMXBean().getHeapMemoryUsage();

  ClusterStatusProtos.ServerLoad.Builder serverLoad =
    ClusterStatusProtos.ServerLoad.newBuilder();
  serverLoad.setNumberOfRequests((int) regionServerWrapper.getRequestsPerSecond());
  serverLoad.setTotalNumberOfRequests((int) regionServerWrapper.getTotalRequestCount());
  serverLoad.setUsedHeapMB((int)(memory.getUsed() / 1024 / 1024));
  serverLoad.setMaxHeapMB((int) (memory.getMax() / 1024 / 1024));
  Set<String> coprocessors = this.hlog.getCoprocessorHost().getCoprocessors();
  for (String coprocessor : coprocessors) {
    serverLoad.addCoprocessors(
      Coprocessor.newBuilder().setName(coprocessor).build());
  }
  RegionLoad.Builder regionLoadBldr = RegionLoad.newBuilder();
  RegionSpecifier.Builder regionSpecifier = RegionSpecifier.newBuilder();
  for (HRegion region : regions) {
    serverLoad.addRegionLoads(createRegionLoad(region, regionLoadBldr, regionSpecifier));
  }
  serverLoad.setReportStartTime(reportStartTime);
  serverLoad.setReportEndTime(reportEndTime);
  if (this.infoServer != null) {
    serverLoad.setInfoServerPort(this.infoServer.getPort());
  } else {
    serverLoad.setInfoServerPort(-1);
  }
  return serverLoad.build();
}

项目：HIndex 文件：ServerLoad.java

/**
 * Return the RegionServer-level coprocessors
 * @return string array of loaded RegionServer-level coprocessors
 */
public String[] getRegionServerCoprocessors() {
  List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList();
  String [] ret = new String[list.size()];
  int i = 0;
  for (Coprocessor elem : list) {
    ret[i++] = elem.getName();
  }

  return ret;
}

项目：HIndex 文件：ServerLoad.java

/**
 * Return the RegionServer-level and Region-level coprocessors
 * @return string array of loaded RegionServer-level and
 *         Region-level coprocessors
 */
public String[] getRsCoprocessors() {
  // Need a set to remove duplicates, but since generated Coprocessor class
  // is not Comparable, make it a Set<String> instead of Set<Coprocessor>
  TreeSet<String> coprocessSet = new TreeSet<String>();
  for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) {
    coprocessSet.add(coprocessor.getName());
  }
  return coprocessSet.toArray(new String[0]);
}

项目：PyroDB 文件：HRegionServer.java

ClusterStatusProtos.ServerLoad buildServerLoad(long reportStartTime, long reportEndTime) {
  // We're getting the MetricsRegionServerWrapper here because the wrapper computes requests
  // per second, and other metrics  As long as metrics are part of ServerLoad it's best to use
  // the wrapper to compute those numbers in one place.
  // In the long term most of these should be moved off of ServerLoad and the heart beat.
  // Instead they should be stored in an HBase table so that external visibility into HBase is
  // improved; Additionally the load balancer will be able to take advantage of a more complete
  // history.
  MetricsRegionServerWrapper regionServerWrapper = this.metricsRegionServer.getRegionServerWrapper();
  Collection<HRegion> regions = getOnlineRegionsLocalContext();
  MemoryUsage memory =
    ManagementFactory.getMemoryMXBean().getHeapMemoryUsage();

  ClusterStatusProtos.ServerLoad.Builder serverLoad =
    ClusterStatusProtos.ServerLoad.newBuilder();
  serverLoad.setNumberOfRequests((int) regionServerWrapper.getRequestsPerSecond());
  serverLoad.setTotalNumberOfRequests((int) regionServerWrapper.getTotalRequestCount());
  serverLoad.setUsedHeapMB((int)(memory.getUsed() / 1024 / 1024));
  serverLoad.setMaxHeapMB((int) (memory.getMax() / 1024 / 1024));
  Set<String> coprocessors = this.hlog.getCoprocessorHost().getCoprocessors();
  for (String coprocessor : coprocessors) {
    serverLoad.addCoprocessors(
      Coprocessor.newBuilder().setName(coprocessor).build());
  }
  RegionLoad.Builder regionLoadBldr = RegionLoad.newBuilder();
  RegionSpecifier.Builder regionSpecifier = RegionSpecifier.newBuilder();
  for (HRegion region : regions) {
    serverLoad.addRegionLoads(createRegionLoad(region, regionLoadBldr, regionSpecifier));
  }
  serverLoad.setReportStartTime(reportStartTime);
  serverLoad.setReportEndTime(reportEndTime);
  if (this.infoServer != null) {
    serverLoad.setInfoServerPort(this.infoServer.getPort());
  } else {
    serverLoad.setInfoServerPort(-1);
  }
  return serverLoad.build();
}

项目：PyroDB 文件：ServerLoad.java

/**
 * Return the RegionServer-level coprocessors
 * @return string array of loaded RegionServer-level coprocessors
 */
public String[] getRegionServerCoprocessors() {
  List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList();
  String [] ret = new String[list.size()];
  int i = 0;
  for (Coprocessor elem : list) {
    ret[i++] = elem.getName();
  }

  return ret;
}

项目：PyroDB 文件：ServerLoad.java

/**
 * Return the RegionServer-level and Region-level coprocessors
 * @return string array of loaded RegionServer-level and
 *         Region-level coprocessors
 */
public String[] getRsCoprocessors() {
  // Need a set to remove duplicates, but since generated Coprocessor class
  // is not Comparable, make it a Set<String> instead of Set<Coprocessor>
  TreeSet<String> coprocessSet = new TreeSet<String>();
  for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) {
    coprocessSet.add(coprocessor.getName());
  }
  return coprocessSet.toArray(new String[0]);
}

项目：c5 文件：HRegionServer.java

ClusterStatusProtos.ServerLoad buildServerLoad(long reportStartTime, long reportEndTime) {
  // We're getting the MetricsRegionServerWrapper here because the wrapper computes requests
  // per second, and other metrics  As long as metrics are part of ServerLoad it's best to use
  // the wrapper to compute those numbers in one place.
  // In the long term most of these should be moved off of ServerLoad and the heart beat.
  // Instead they should be stored in an HBase table so that external visibility into HBase is
  // improved; Additionally the load balancer will be able to take advantage of a more complete
  // history.
  MetricsRegionServerWrapper regionServerWrapper = this.metricsRegionServer.getRegionServerWrapper();
  Collection<HRegion> regions = getOnlineRegionsLocalContext();
  MemoryUsage memory =
    ManagementFactory.getMemoryMXBean().getHeapMemoryUsage();

  ClusterStatusProtos.ServerLoad.Builder serverLoad =
    ClusterStatusProtos.ServerLoad.newBuilder();
  serverLoad.setNumberOfRequests((int) regionServerWrapper.getRequestsPerSecond());
  serverLoad.setTotalNumberOfRequests((int) regionServerWrapper.getTotalRequestCount());
  serverLoad.setUsedHeapMB((int)(memory.getUsed() / 1024 / 1024));
  serverLoad.setMaxHeapMB((int) (memory.getMax() / 1024 / 1024));
  Set<String> coprocessors = this.hlog.getCoprocessorHost().getCoprocessors();
  for (String coprocessor : coprocessors) {
    serverLoad.addCoprocessors(
      Coprocessor.newBuilder().setName(coprocessor).build());
  }
  for (HRegion region : regions) {
    serverLoad.addRegionLoads(createRegionLoad(region));
  }
  serverLoad.setReportStartTime(reportStartTime);
  serverLoad.setReportEndTime(reportEndTime);
  if (this.infoServer != null) {
    serverLoad.setInfoServerPort(this.infoServer.getPort());
  } else {
    serverLoad.setInfoServerPort(-1);
  }
  return serverLoad.build();
}

项目：c5 文件：ServerLoad.java

/**
 * Return the RegionServer-level coprocessors
 * @return string array of loaded RegionServer-level coprocessors
 */
public String[] getRegionServerCoprocessors() {
  List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList();
  String [] ret = new String[list.size()];
  int i = 0;
  for (Coprocessor elem : list) {
    ret[i++] = elem.getName();
  }

  return ret;
}

项目：c5 文件：ServerLoad.java

/**
 * Return the RegionServer-level and Region-level coprocessors
 * @return string array of loaded RegionServer-level and
 *         Region-level coprocessors
 */
public String[] getRsCoprocessors() {
  // Need a set to remove duplicates, but since generated Coprocessor class
  // is not Comparable, make it a Set<String> instead of Set<Coprocessor>
  TreeSet<String> coprocessSet = new TreeSet<String>();
  for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) {
    coprocessSet.add(coprocessor.getName());
  }
  return coprocessSet.toArray(new String[0]);
}

项目：DominoHBase 文件：ServerLoad.java

/**
 * Return the RegionServer-level coprocessors
 * @return string array of loaded RegionServer-level coprocessors
 */
public String[] getRegionServerCoprocessors() {
  List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList();
  String [] ret = new String[list.size()];
  int i = 0;
  for (Coprocessor elem : list) {
    ret[i++] = elem.getName();
  }

  return ret;
}

项目：DominoHBase 文件：ServerLoad.java

/**
 * Return the RegionServer-level and Region-level coprocessors
 * @return string array of loaded RegionServer-level and
 *         Region-level coprocessors
 */
public String[] getRsCoprocessors() {
  // Need a set to remove duplicates, but since generated Coprocessor class
  // is not Comparable, make it a Set<String> instead of Set<Coprocessor>
  TreeSet<String> coprocessSet = new TreeSet<String>();
  for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) {
    coprocessSet.add(coprocessor.getName());
  }
  return coprocessSet.toArray(new String[0]);
}

项目：DominoHBase 文件：HRegionServer.java

HBaseProtos.ServerLoad buildServerLoad(long reportStartTime, long reportEndTime) {
  // We're getting the MetricsRegionServerWrapper here because the wrapper computes requests
  // per second, and other metrics  As long as metrics are part of ServerLoad it's best to use
  // the wrapper to compute those numbers in one place.
  // In the long term most of these should be moved off of ServerLoad and the heart beat.
  // Instead they should be stored in an HBase table so that external visibility into HBase is
  // improved; Additionally the load balancer will be able to take advantage of a more complete
  // history.
  MetricsRegionServerWrapper regionServerWrapper = this.metricsRegionServer.getRegionServerWrapper();
  Collection<HRegion> regions = getOnlineRegionsLocalContext();
  MemoryUsage memory =
    ManagementFactory.getMemoryMXBean().getHeapMemoryUsage();

  HBaseProtos.ServerLoad.Builder serverLoad = HBaseProtos.ServerLoad.newBuilder();
  serverLoad.setNumberOfRequests((int) regionServerWrapper.getRequestsPerSecond());
  serverLoad.setTotalNumberOfRequests((int) regionServerWrapper.getTotalRequestCount());
  serverLoad.setUsedHeapMB((int)(memory.getUsed() / 1024 / 1024));
  serverLoad.setMaxHeapMB((int) (memory.getMax() / 1024 / 1024));
  Set<String> coprocessors = this.hlog.getCoprocessorHost().getCoprocessors();
  for (String coprocessor : coprocessors) {
    serverLoad.addCoprocessors(
      Coprocessor.newBuilder().setName(coprocessor).build());
  }
  for (HRegion region : regions) {
    serverLoad.addRegionLoads(createRegionLoad(region));
  }
  serverLoad.setReportStartTime(reportStartTime);
  serverLoad.setReportEndTime(reportEndTime);
  if (this.infoServer != null) {
    serverLoad.setInfoServerPort(this.infoServer.getPort());
  } else {
    serverLoad.setInfoServerPort(-1);
  }
  return serverLoad.build();
}