Java 类org.apache.hadoop.hbase.protobuf.generated.ClusterStatusProtos.RegionInTransition 实例源码

项目：DominoHBase 文件：ClusterStatus.java

/**
  * Convert a ClutserStatus to a protobuf ClusterStatus
  *
  * @return the protobuf ClusterStatus
  */
public ClusterStatusProtos.ClusterStatus convert() {
  ClusterStatusProtos.ClusterStatus.Builder builder = ClusterStatusProtos.ClusterStatus.newBuilder();
  builder.setHbaseVersion(HBaseVersionFileContent.newBuilder().setVersion(getHBaseVersion()));

  for (Map.Entry<ServerName, ServerLoad> entry : liveServers.entrySet()) {
    LiveServerInfo.Builder lsi =
      LiveServerInfo.newBuilder().setServer(ProtobufUtil.toServerName(entry.getKey()));
    lsi.setServerLoad(entry.getValue().obtainServerLoadPB());
    builder.addLiveServers(lsi.build());
  }
  for (ServerName deadServer : getDeadServerNames()) {
    builder.addDeadServers(ProtobufUtil.toServerName(deadServer));
  }
  for (Map.Entry<String, RegionState> rit : getRegionsInTransition().entrySet()) {
    ClusterStatusProtos.RegionState rs = rit.getValue().convert();
    RegionSpecifier.Builder spec =
      RegionSpecifier.newBuilder().setType(RegionSpecifierType.REGION_NAME);
    spec.setValue(ByteString.copyFrom(Bytes.toBytes(rit.getKey())));

    RegionInTransition pbRIT =
      RegionInTransition.newBuilder().setSpec(spec.build()).setRegionState(rs).build();
    builder.addRegionsInTransition(pbRIT);
  }
  builder.setClusterId(new ClusterId(getClusterId()).convert());
  for (String coprocessor : getMasterCoprocessors()) {
    builder.addMasterCoprocessors(HBaseProtos.Coprocessor.newBuilder().setName(coprocessor));
  }
  builder.setMaster(
    ProtobufUtil.toServerName(getMaster()));
  for (ServerName backup : getBackupMasters()) {
    builder.addBackupMasters(ProtobufUtil.toServerName(backup));
  }
  builder.setBalancerOn(balancerOn);
  return builder.build();
}

项目：ditb 文件：ClusterStatus.java

/**
  * Convert a ClusterStatus to a protobuf ClusterStatus
  *
  * @return the protobuf ClusterStatus
  */
public ClusterStatusProtos.ClusterStatus convert() {
  ClusterStatusProtos.ClusterStatus.Builder builder =
      ClusterStatusProtos.ClusterStatus.newBuilder();
  builder.setHbaseVersion(HBaseVersionFileContent.newBuilder().setVersion(getHBaseVersion()));

  if (liveServers != null){
    for (Map.Entry<ServerName, ServerLoad> entry : liveServers.entrySet()) {
      LiveServerInfo.Builder lsi =
        LiveServerInfo.newBuilder().setServer(ProtobufUtil.toServerName(entry.getKey()));
      lsi.setServerLoad(entry.getValue().obtainServerLoadPB());
      builder.addLiveServers(lsi.build());
    }
  }

  if (deadServers != null){
    for (ServerName deadServer : deadServers) {
      builder.addDeadServers(ProtobufUtil.toServerName(deadServer));
    }
  }

  if (intransition != null) {
    for (Map.Entry<String, RegionState> rit : getRegionsInTransition().entrySet()) {
      ClusterStatusProtos.RegionState rs = rit.getValue().convert();
      RegionSpecifier.Builder spec =
          RegionSpecifier.newBuilder().setType(RegionSpecifierType.REGION_NAME);
      spec.setValue(ByteStringer.wrap(Bytes.toBytes(rit.getKey())));

      RegionInTransition pbRIT =
          RegionInTransition.newBuilder().setSpec(spec.build()).setRegionState(rs).build();
      builder.addRegionsInTransition(pbRIT);
    }
  }

  if (clusterId != null) {
    builder.setClusterId(new ClusterId(clusterId).convert());
  }

  if (masterCoprocessors != null) {
    for (String coprocessor : masterCoprocessors) {
      builder.addMasterCoprocessors(HBaseProtos.Coprocessor.newBuilder().setName(coprocessor));
    }
  }

  if (master != null){
    builder.setMaster(ProtobufUtil.toServerName(getMaster()));
  }

  if (backupMasters != null) {
    for (ServerName backup : backupMasters) {
      builder.addBackupMasters(ProtobufUtil.toServerName(backup));
    }
  }

  if (balancerOn != null){
    builder.setBalancerOn(balancerOn);
  }

  return builder.build();
}

项目：pbase 文件：ClusterStatus.java

/**
  * Convert a ClusterStatus to a protobuf ClusterStatus
  *
  * @return the protobuf ClusterStatus
  */
public ClusterStatusProtos.ClusterStatus convert() {
  ClusterStatusProtos.ClusterStatus.Builder builder =
      ClusterStatusProtos.ClusterStatus.newBuilder();
  builder.setHbaseVersion(HBaseVersionFileContent.newBuilder().setVersion(getHBaseVersion()));

  if (liveServers != null){
    for (Map.Entry<ServerName, ServerLoad> entry : liveServers.entrySet()) {
      LiveServerInfo.Builder lsi =
        LiveServerInfo.newBuilder().setServer(ProtobufUtil.toServerName(entry.getKey()));
      lsi.setServerLoad(entry.getValue().obtainServerLoadPB());
      builder.addLiveServers(lsi.build());
    }
  }

  if (deadServers != null){
    for (ServerName deadServer : deadServers) {
      builder.addDeadServers(ProtobufUtil.toServerName(deadServer));
    }
  }

  if (intransition != null) {
    for (Map.Entry<String, RegionState> rit : getRegionsInTransition().entrySet()) {
      ClusterStatusProtos.RegionState rs = rit.getValue().convert();
      RegionSpecifier.Builder spec =
          RegionSpecifier.newBuilder().setType(RegionSpecifierType.REGION_NAME);
      spec.setValue(ByteStringer.wrap(Bytes.toBytes(rit.getKey())));

      RegionInTransition pbRIT =
          RegionInTransition.newBuilder().setSpec(spec.build()).setRegionState(rs).build();
      builder.addRegionsInTransition(pbRIT);
    }
  }

  if (clusterId != null) {
    builder.setClusterId(new ClusterId(clusterId).convert());
  }

  if (masterCoprocessors != null) {
    for (String coprocessor : masterCoprocessors) {
      builder.addMasterCoprocessors(HBaseProtos.Coprocessor.newBuilder().setName(coprocessor));
    }
  }

  if (master != null){
    builder.setMaster(ProtobufUtil.toServerName(getMaster()));
  }

  if (backupMasters != null) {
    for (ServerName backup : backupMasters) {
      builder.addBackupMasters(ProtobufUtil.toServerName(backup));
    }
  }

  if (balancerOn != null){
    builder.setBalancerOn(balancerOn);
  }

  return builder.build();
}

项目：HIndex 文件：ClusterStatus.java

/**
  * Convert a ClusterStatus to a protobuf ClusterStatus
  *
  * @return the protobuf ClusterStatus
  */
public ClusterStatusProtos.ClusterStatus convert() {
  ClusterStatusProtos.ClusterStatus.Builder builder =
      ClusterStatusProtos.ClusterStatus.newBuilder();
  builder.setHbaseVersion(HBaseVersionFileContent.newBuilder().setVersion(getHBaseVersion()));

  if (liveServers != null){
    for (Map.Entry<ServerName, ServerLoad> entry : liveServers.entrySet()) {
      LiveServerInfo.Builder lsi =
        LiveServerInfo.newBuilder().setServer(ProtobufUtil.toServerName(entry.getKey()));
      lsi.setServerLoad(entry.getValue().obtainServerLoadPB());
      builder.addLiveServers(lsi.build());
    }
  }

  if (deadServers != null){
    for (ServerName deadServer : deadServers) {
      builder.addDeadServers(ProtobufUtil.toServerName(deadServer));
    }
  }

  if (intransition != null) {
    for (Map.Entry<String, RegionState> rit : getRegionsInTransition().entrySet()) {
      ClusterStatusProtos.RegionState rs = rit.getValue().convert();
      RegionSpecifier.Builder spec =
          RegionSpecifier.newBuilder().setType(RegionSpecifierType.REGION_NAME);
      spec.setValue(HBaseZeroCopyByteString.wrap(Bytes.toBytes(rit.getKey())));

      RegionInTransition pbRIT =
          RegionInTransition.newBuilder().setSpec(spec.build()).setRegionState(rs).build();
      builder.addRegionsInTransition(pbRIT);
    }
  }

  if (clusterId != null) {
    builder.setClusterId(new ClusterId(clusterId).convert());
  }

  if (masterCoprocessors != null) {
    for (String coprocessor : masterCoprocessors) {
      builder.addMasterCoprocessors(HBaseProtos.Coprocessor.newBuilder().setName(coprocessor));
    }
  }

  if (master != null){
    builder.setMaster(ProtobufUtil.toServerName(getMaster()));
  }

  if (backupMasters != null) {
    for (ServerName backup : backupMasters) {
      builder.addBackupMasters(ProtobufUtil.toServerName(backup));
    }
  }

  if (balancerOn != null){
    builder.setBalancerOn(balancerOn);
  }

  return builder.build();
}

项目：PyroDB 文件：ClusterStatus.java

/**
  * Convert a ClusterStatus to a protobuf ClusterStatus
  *
  * @return the protobuf ClusterStatus
  */
public ClusterStatusProtos.ClusterStatus convert() {
  ClusterStatusProtos.ClusterStatus.Builder builder =
      ClusterStatusProtos.ClusterStatus.newBuilder();
  builder.setHbaseVersion(HBaseVersionFileContent.newBuilder().setVersion(getHBaseVersion()));

  if (liveServers != null){
    for (Map.Entry<ServerName, ServerLoad> entry : liveServers.entrySet()) {
      LiveServerInfo.Builder lsi =
        LiveServerInfo.newBuilder().setServer(ProtobufUtil.toServerName(entry.getKey()));
      lsi.setServerLoad(entry.getValue().obtainServerLoadPB());
      builder.addLiveServers(lsi.build());
    }
  }

  if (deadServers != null){
    for (ServerName deadServer : deadServers) {
      builder.addDeadServers(ProtobufUtil.toServerName(deadServer));
    }
  }

  if (intransition != null) {
    for (Map.Entry<String, RegionState> rit : getRegionsInTransition().entrySet()) {
      ClusterStatusProtos.RegionState rs = rit.getValue().convert();
      RegionSpecifier.Builder spec =
          RegionSpecifier.newBuilder().setType(RegionSpecifierType.REGION_NAME);
      spec.setValue(HBaseZeroCopyByteString.wrap(Bytes.toBytes(rit.getKey())));

      RegionInTransition pbRIT =
          RegionInTransition.newBuilder().setSpec(spec.build()).setRegionState(rs).build();
      builder.addRegionsInTransition(pbRIT);
    }
  }

  if (clusterId != null) {
    builder.setClusterId(new ClusterId(clusterId).convert());
  }

  if (masterCoprocessors != null) {
    for (String coprocessor : masterCoprocessors) {
      builder.addMasterCoprocessors(HBaseProtos.Coprocessor.newBuilder().setName(coprocessor));
    }
  }

  if (master != null){
    builder.setMaster(ProtobufUtil.toServerName(getMaster()));
  }

  if (backupMasters != null) {
    for (ServerName backup : backupMasters) {
      builder.addBackupMasters(ProtobufUtil.toServerName(backup));
    }
  }

  if (balancerOn != null){
    builder.setBalancerOn(balancerOn);
  }

  return builder.build();
}

项目：c5 文件：ClusterStatus.java

/**
  * Convert a ClusterStatus to a protobuf ClusterStatus
  *
  * @return the protobuf ClusterStatus
  */
public ClusterStatusProtos.ClusterStatus convert() {
  ClusterStatusProtos.ClusterStatus.Builder builder =
      ClusterStatusProtos.ClusterStatus.newBuilder();
  builder.setHbaseVersion(HBaseVersionFileContent.newBuilder().setVersion(getHBaseVersion()));

  if (liveServers != null){
    for (Map.Entry<ServerName, ServerLoad> entry : liveServers.entrySet()) {
      LiveServerInfo.Builder lsi =
        LiveServerInfo.newBuilder().setServer(ProtobufUtil.toServerName(entry.getKey()));
      lsi.setServerLoad(entry.getValue().obtainServerLoadPB());
      builder.addLiveServers(lsi.build());
    }
  }

  if (deadServers != null){
    for (ServerName deadServer : deadServers) {
      builder.addDeadServers(ProtobufUtil.toServerName(deadServer));
    }
  }

  if (intransition != null) {
    for (Map.Entry<String, RegionState> rit : getRegionsInTransition().entrySet()) {
      ClusterStatusProtos.RegionState rs = rit.getValue().convert();
      RegionSpecifier.Builder spec =
          RegionSpecifier.newBuilder().setType(RegionSpecifierType.REGION_NAME);
      spec.setValue(ZeroCopyLiteralByteString.wrap(Bytes.toBytes(rit.getKey())));

      RegionInTransition pbRIT =
          RegionInTransition.newBuilder().setSpec(spec.build()).setRegionState(rs).build();
      builder.addRegionsInTransition(pbRIT);
    }
  }

  if (clusterId != null) {
    builder.setClusterId(new ClusterId(clusterId).convert());
  }

  if (masterCoprocessors != null) {
    for (String coprocessor : masterCoprocessors) {
      builder.addMasterCoprocessors(HBaseProtos.Coprocessor.newBuilder().setName(coprocessor));
    }
  }

  if (master != null){
    builder.setMaster(ProtobufUtil.toServerName(getMaster()));
  }

  if (backupMasters != null) {
    for (ServerName backup : backupMasters) {
      builder.addBackupMasters(ProtobufUtil.toServerName(backup));
    }
  }

  if (balancerOn != null){
    builder.setBalancerOn(balancerOn);
  }

  return builder.build();
}