org.apache.hadoop.hbase.net.Address.fromParts()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(11.8k)|赞(0)|评价(0)|浏览(102)

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

Address.fromParts介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

protected ServerName(final String hostname, final int port, final long startcode) {
 this(Address.fromParts(hostname, port), startcode);
}

代码示例来源：origin: apache/hbase

/**
 * If hostname is a.b.c and the port is 123, return a:123 instead of a.b.c:123.
 * @return if host looks like it is resolved -- not an IP -- then strip the domain portion
 * otherwise returns same as {@link #toString()}}
 */
public String toStringWithoutDomain() {
 String hostname = getHostname();
 String [] parts = hostname.split("\\.");
 if (parts.length > 1) {
  for (String part: parts) {
   if (!StringUtils.isNumeric(part)) {
    return Address.fromParts(parts[0], getPort()).toString();
   }
  }
 }
 return toString();
}

代码示例来源：origin: apache/hbase

Address.fromParts(initialIsa.getHostName(), initialIsa.getPort()).toStringWithoutDomain();

代码示例来源：origin: apache/hbase

private SortedSet<Address> getDefaultServers() throws IOException {
 SortedSet<Address> defaultServers = Sets.newTreeSet();
 for (ServerName serverName : getOnlineRS()) {
  Address server = Address.fromParts(serverName.getHostname(), serverName.getPort());
  boolean found = false;
  for (RSGroupInfo rsgi : listRSGroups()) {
   if (!RSGroupInfo.DEFAULT_GROUP.equals(rsgi.getName()) && rsgi.containsServer(server)) {
    found = true;
    break;
   }
  }
  if (!found) {
   defaultServers.add(server);
  }
 }
 return defaultServers;
}

代码示例来源：origin: apache/hbase

@Test
 public void testGetHostWithoutDomain() {
  assertEquals("a:123",
    Address.fromParts("a.b.c", 123).toStringWithoutDomain());
  assertEquals("1:123",
    Address.fromParts("1.b.c", 123).toStringWithoutDomain());
  assertEquals("123.456.789.1:123",
    Address.fromParts("123.456.789.1", 123).toStringWithoutDomain());
  assertEquals("[2001:db8::1]:80",
    Address.fromParts("[2001:db8::1]:", 80).toStringWithoutDomain());
  assertEquals("[2001:db8::1]:80",
    Address.fromParts("[2001:db8::1]:", 80).toStringWithoutDomain());
 }
}

代码示例来源：origin: apache/hbase

public static RSGroupInfo toGroupInfo(RSGroupProtos.RSGroupInfo proto) {
 RSGroupInfo RSGroupInfo = new RSGroupInfo(proto.getName());
 for(HBaseProtos.ServerName el: proto.getServersList()) {
  RSGroupInfo.addServer(Address.fromParts(el.getHostName(), el.getPort()));
 }
 for(HBaseProtos.TableName pTableName: proto.getTablesList()) {
  RSGroupInfo.addTable(ProtobufUtil.toTableName(pTableName));
 }
 return RSGroupInfo;
}

代码示例来源：origin: apache/hbase

static RSGroupInfo toGroupInfo(RSGroupProtos.RSGroupInfo proto) {
 RSGroupInfo RSGroupInfo = new RSGroupInfo(proto.getName());
 for(HBaseProtos.ServerName el: proto.getServersList()) {
  RSGroupInfo.addServer(Address.fromParts(el.getHostName(), el.getPort()));
 }
 for(HBaseProtos.TableName pTableName: proto.getTablesList()) {
  RSGroupInfo.addTable(ProtobufUtil.toTableName(pTableName));
 }
 return RSGroupInfo;
}

代码示例来源：origin: apache/hbase

@Override
public void moveServersAndTables(RpcController controller,
  MoveServersAndTablesRequest request, RpcCallback<MoveServersAndTablesResponse> done) {
 MoveServersAndTablesResponse.Builder builder = MoveServersAndTablesResponse.newBuilder();
 Set<Address> hostPorts = Sets.newHashSet();
 for (HBaseProtos.ServerName el : request.getServersList()) {
  hostPorts.add(Address.fromParts(el.getHostName(), el.getPort()));
 }
 Set<TableName> tables = new HashSet<>(request.getTableNameList().size());
 for (HBaseProtos.TableName tableName : request.getTableNameList()) {
  tables.add(ProtobufUtil.toTableName(tableName));
 }
 LOG.info(master.getClientIdAuditPrefix() + " move servers " + hostPorts
   + " and tables " + tables + " to rsgroup" + request.getTargetGroup());
 try {
  if (master.getMasterCoprocessorHost() != null) {
   master.getMasterCoprocessorHost().preMoveServersAndTables(hostPorts, tables,
     request.getTargetGroup());
  }
  checkPermission("moveServersAndTables");
  groupAdminServer.moveServersAndTables(hostPorts, tables, request.getTargetGroup());
  if (master.getMasterCoprocessorHost() != null) {
   master.getMasterCoprocessorHost().postMoveServersAndTables(hostPorts, tables,
     request.getTargetGroup());
  }
 } catch (IOException e) {
  CoprocessorRpcUtils.setControllerException(controller, e);
 }
 done.run(builder.build());
}

代码示例来源：origin: apache/hbase

@Override
 public void removeServers(RpcController controller,
   RemoveServersRequest request,
   RpcCallback<RemoveServersResponse> done) {
  RemoveServersResponse.Builder builder =
    RemoveServersResponse.newBuilder();
  Set<Address> servers = Sets.newHashSet();
  for (HBaseProtos.ServerName el : request.getServersList()) {
   servers.add(Address.fromParts(el.getHostName(), el.getPort()));
  }
  LOG.info(master.getClientIdAuditPrefix()
    + " remove decommissioned servers from rsgroup: " + servers);
  try {
   if (master.getMasterCoprocessorHost() != null) {
    master.getMasterCoprocessorHost().preRemoveServers(servers);
   }
   checkPermission("removeServers");
   groupAdminServer.removeServers(servers);
   if (master.getMasterCoprocessorHost() != null) {
    master.getMasterCoprocessorHost().postRemoveServers(servers);
   }
  } catch (IOException e) {
   CoprocessorRpcUtils.setControllerException(controller, e);
  }
  done.run(builder.build());
 }
}

代码示例来源：origin: apache/hbase

@Override
public void moveServers(RpcController controller, MoveServersRequest request,
  RpcCallback<MoveServersResponse> done) {
 MoveServersResponse.Builder builder = MoveServersResponse.newBuilder();
 Set<Address> hostPorts = Sets.newHashSet();
 for (HBaseProtos.ServerName el : request.getServersList()) {
  hostPorts.add(Address.fromParts(el.getHostName(), el.getPort()));
 }
 LOG.info(master.getClientIdAuditPrefix() + " move servers " + hostPorts +" to rsgroup "
   + request.getTargetGroup());
 try {
  if (master.getMasterCoprocessorHost() != null) {
   master.getMasterCoprocessorHost().preMoveServers(hostPorts, request.getTargetGroup());
  }
  checkPermission("moveServers");
  groupAdminServer.moveServers(hostPorts, request.getTargetGroup());
  if (master.getMasterCoprocessorHost() != null) {
   master.getMasterCoprocessorHost().postMoveServers(hostPorts, request.getTargetGroup());
  }
 } catch (IOException e) {
  CoprocessorRpcUtils.setControllerException(controller, e);
 }
 done.run(builder.build());
}

代码示例来源：origin: apache/hbase

@Override
public void getRSGroupInfoOfServer(RpcController controller,
  GetRSGroupInfoOfServerRequest request, RpcCallback<GetRSGroupInfoOfServerResponse> done) {
 GetRSGroupInfoOfServerResponse.Builder builder = GetRSGroupInfoOfServerResponse.newBuilder();
 Address hp = Address.fromParts(request.getServer().getHostName(),
   request.getServer().getPort());
 LOG.info(master.getClientIdAuditPrefix() + " initiates rsgroup info retrieval, server="
   + hp);
 try {
  if (master.getMasterCoprocessorHost() != null) {
   master.getMasterCoprocessorHost().preGetRSGroupInfoOfServer(hp);
  }
  checkPermission("getRSGroupInfoOfServer");
  RSGroupInfo info = groupAdminServer.getRSGroupOfServer(hp);
  if (info != null) {
   builder.setRSGroupInfo(RSGroupProtobufUtil.toProtoGroupInfo(info));
  }
  if (master.getMasterCoprocessorHost() != null) {
   master.getMasterCoprocessorHost().postGetRSGroupInfoOfServer(hp);
  }
 } catch (IOException e) {
  CoprocessorRpcUtils.setControllerException(controller, e);
 }
 done.run(builder.build());
}

代码示例来源：origin: apache/hbase

@Test
public void testBogusArgs() throws Exception {
 assertNull(rsGroupAdmin.getRSGroupInfoOfTable(TableName.valueOf("nonexistent")));
 assertNull(rsGroupAdmin.getRSGroupOfServer(Address.fromParts("bogus", 123)));
 assertNull(rsGroupAdmin.getRSGroupInfo("bogus"));
  rsGroupAdmin.moveServers(Sets.newHashSet(Address.fromParts("bogus", 123)), "bogus");
  fail("Expected move with bogus group to fail");
 } catch (ConstraintException ex) {

代码示例来源：origin: apache/hbase

@Test
public void testNonExistentTableMove() throws Exception {
 TableName tableName = TableName.valueOf(tablePrefix + name.getMethodName());
 RSGroupInfo tableGrp = rsGroupAdmin.getRSGroupInfoOfTable(tableName);
 assertNull(tableGrp);
 // test if table exists already.
 boolean exist = admin.tableExists(tableName);
 assertFalse(exist);
 LOG.info("Moving table " + tableName + " to " + RSGroupInfo.DEFAULT_GROUP);
 try {
  rsGroupAdmin.moveTables(Sets.newHashSet(tableName), RSGroupInfo.DEFAULT_GROUP);
  fail("Table " + tableName + " shouldn't have been successfully moved.");
 } catch (IOException ex) {
  assertTrue(ex instanceof TableNotFoundException);
 }
 try {
  rsGroupAdmin.moveServersAndTables(Sets.newHashSet(Address.fromParts("bogus", 123)),
   Sets.newHashSet(tableName), RSGroupInfo.DEFAULT_GROUP);
  fail("Table " + tableName + " shouldn't have been successfully moved.");
 } catch (IOException ex) {
  assertTrue(ex instanceof TableNotFoundException);
 }
 // verify group change
 assertNull(rsGroupAdmin.getRSGroupInfoOfTable(tableName));
}

代码示例来源：origin: org.apache.hbase/hbase-client

public static RSGroupInfo toGroupInfo(RSGroupProtos.RSGroupInfo proto) {
 RSGroupInfo RSGroupInfo = new RSGroupInfo(proto.getName());
 for(HBaseProtos.ServerName el: proto.getServersList()) {
  RSGroupInfo.addServer(Address.fromParts(el.getHostName(), el.getPort()));
 }
 for(TableProtos.TableName pTableName: proto.getTablesList()) {
  RSGroupInfo.addTable(ProtobufUtil.toTableName(pTableName));
 }
 return RSGroupInfo;
}

代码示例来源：origin: org.apache.hbase/hbase-common

protected ServerName(final String hostname, final int port, final long startcode) {
 this(Address.fromParts(hostname, port), startcode);
}

代码示例来源：origin: org.apache.hbase/hbase-common

@Test
 public void testGetHostWithoutDomain() {
  assertEquals("a:123",
    Address.fromParts("a.b.c", 123).toStringWithoutDomain());
  assertEquals("1:123",
    Address.fromParts("1.b.c", 123).toStringWithoutDomain());
  assertEquals("123.456.789.1:123",
    Address.fromParts("123.456.789.1", 123).toStringWithoutDomain());
  assertEquals("[2001:db8::1]:80",
    Address.fromParts("[2001:db8::1]:", 80).toStringWithoutDomain());
  assertEquals("[2001:db8::1]:80",
    Address.fromParts("[2001:db8::1]:", 80).toStringWithoutDomain());
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-common

@Test
 public void testGetHostWithoutDomain() {
  assertEquals("a:123",
    Address.fromParts("a.b.c", 123).toStringWithoutDomain());
  assertEquals("1:123",
    Address.fromParts("1.b.c", 123).toStringWithoutDomain());
  assertEquals("123.456.789.1:123",
    Address.fromParts("123.456.789.1", 123).toStringWithoutDomain());
  assertEquals("[2001:db8::1]:80",
    Address.fromParts("[2001:db8::1]:", 80).toStringWithoutDomain());
  assertEquals("[2001:db8::1]:80",
    Address.fromParts("[2001:db8::1]:", 80).toStringWithoutDomain());
 }
}

代码示例来源：origin: org.apache.hbase/hbase-rsgroup

static RSGroupInfo toGroupInfo(RSGroupProtos.RSGroupInfo proto) {
 RSGroupInfo RSGroupInfo = new RSGroupInfo(proto.getName());
 for(HBaseProtos.ServerName el: proto.getServersList()) {
  RSGroupInfo.addServer(Address.fromParts(el.getHostName(), el.getPort()));
 }
 for(TableProtos.TableName pTableName: proto.getTablesList()) {
  RSGroupInfo.addTable(ProtobufUtil.toTableName(pTableName));
 }
 return RSGroupInfo;
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

public static RSGroupInfo toGroupInfo(RSGroupProtos.RSGroupInfo proto) {
 RSGroupInfo RSGroupInfo = new RSGroupInfo(proto.getName());
 for(HBaseProtos.ServerName el: proto.getServersList()) {
  RSGroupInfo.addServer(Address.fromParts(el.getHostName(), el.getPort()));
 }
 for(TableProtos.TableName pTableName: proto.getTablesList()) {
  RSGroupInfo.addTable(ProtobufUtil.toTableName(pTableName));
 }
 return RSGroupInfo;
}

代码示例来源：origin: com.aliyun.hbase/alihbase-rsgroup

static RSGroupInfo toGroupInfo(RSGroupProtos.RSGroupInfo proto) {
 RSGroupInfo RSGroupInfo = new RSGroupInfo(proto.getName());
 for(HBaseProtos.ServerName el: proto.getServersList()) {
  RSGroupInfo.addServer(Address.fromParts(el.getHostName(), el.getPort()));
 }
 for(TableProtos.TableName pTableName: proto.getTablesList()) {
  RSGroupInfo.addTable(ProtobufUtil.toTableName(pTableName));
 }
 return RSGroupInfo;
}

内容来源于网络，如有侵权，请联系作者删除！

Address

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com