• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java InfoServer类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.hbase.util.InfoServer类的典型用法代码示例。如果您正苦于以下问题：Java InfoServer类的具体用法？Java InfoServer怎么用？Java InfoServer使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



InfoServer类属于org.apache.hadoop.hbase.util包，在下文中一共展示了InfoServer类的15个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: doMain

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Start up or shuts down the Thrift server, depending on the arguments.
 * @param args
 */
 void doMain(final String[] args) throws Exception {
   processOptions(args);
   // login the server principal (if using secure Hadoop)
   if (User.isSecurityEnabled() && User.isHBaseSecurityEnabled(conf)) {
     String machineName = Strings.domainNamePointerToHostName(
       DNS.getDefaultHost(conf.get("hbase.thrift.dns.interface", "default"),
         conf.get("hbase.thrift.dns.nameserver", "default")));
     User.login(conf, "hbase.thrift.keytab.file",
         "hbase.thrift.kerberos.principal", machineName);
   }
   serverRunner = new ThriftServerRunner(conf);

   // Put up info server.
   int port = conf.getInt("hbase.thrift.info.port", 9095);
   if (port >= 0) {
     conf.setLong("startcode", System.currentTimeMillis());
     String a = conf.get("hbase.thrift.info.bindAddress", "0.0.0.0");
     infoServer = new InfoServer("thrift", a, port, false, conf);
     infoServer.setAttribute("hbase.conf", conf);
     infoServer.start();
   }
   serverRunner.run();
}
开发者ID:zwqjsj0404，项目名称:HBase-Research，代码行数:28，代码来源:ThriftServer.java


示例2: doMain

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Start up or shuts down the Thrift server, depending on the arguments.
 * @param args
 */
 void doMain(final String[] args) throws Exception {
   processOptions(args);
  // login the server principal (if using secure Hadoop)
  UserProvider provider = UserProvider.instantiate(conf);
  if (provider.isHadoopSecurityEnabled() && provider.isHBaseSecurityEnabled()) {
    String machineName =
        Strings.domainNamePointerToHostName(DNS.getDefaultHost(
          conf.get("hbase.thrift.dns.interface", "default"),
          conf.get("hbase.thrift.dns.nameserver", "default")));

    provider.login("hbase.thrift.keytab.file", 
      "hbase.thrift.kerberos.principal", machineName);
  }
   serverRunner = new ThriftServerRunner(conf);

   // Put up info server.
   int port = conf.getInt("hbase.thrift.info.port", 9095);
   if (port >= 0) {
     conf.setLong("startcode", System.currentTimeMillis());
     String a = conf.get("hbase.thrift.info.bindAddress", "0.0.0.0");
     infoServer = new InfoServer("thrift", a, port, false, conf);
     infoServer.setAttribute("hbase.conf", conf);
     infoServer.start();
   }
   serverRunner.run();
}
开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:31，代码来源:ThriftServer.java


示例3: putUpWebUI

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Puts up the webui.
 * @return Returns final port -- maybe different from what we started with.
 * @throws IOException
 */
private int putUpWebUI() throws IOException {
  int port = this.conf.getInt("hbase.regionserver.info.port", 60030);
  // -1 is for disabling info server
  if (port < 0) return port;
  String addr = this.conf.get("hbase.regionserver.info.bindAddress", "0.0.0.0");
  // check if auto port bind enabled
  boolean auto = this.conf.getBoolean(HConstants.REGIONSERVER_INFO_PORT_AUTO, false);
  while (true) {
    try {
      this.infoServer = new InfoServer("regionserver", addr, port, false, this.conf);
      this.infoServer.addServlet("status", "/rs-status", RSStatusServlet.class);
      this.infoServer.addServlet("dump", "/dump", RSDumpServlet.class);
      this.infoServer.setAttribute(REGIONSERVER, this);
      this.infoServer.setAttribute(REGIONSERVER_CONF, conf);
      this.infoServer.start();
      break;
    } catch (BindException e) {
      if (!auto) {
        // auto bind disabled throw BindException
        throw e;
      }
      // auto bind enabled, try to use another port
      LOG.info("Failed binding http info server to port: " + port);
      port++;
    }
  }
  return port;
}
开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:34，代码来源:HRegionServer.java


示例4: doMain

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Start up or shuts down the Thrift server, depending on the arguments.
 * @param args
 */
 void doMain(final String[] args) throws Exception {
   processOptions(args);

  UserProvider userProvider = UserProvider.instantiate(conf);
  // login the server principal (if using secure Hadoop)
  if (userProvider.isHadoopSecurityEnabled() && userProvider.isHBaseSecurityEnabled()) {
    String machineName =
        Strings.domainNamePointerToHostName(DNS.getDefaultHost(
          conf.get("hbase.thrift.dns.interface", "default"),
          conf.get("hbase.thrift.dns.nameserver", "default")));
    userProvider
        .login("hbase.thrift.keytab.file", "hbase.thrift.kerberos.principal", machineName);
  }

   serverRunner = new ThriftServerRunner(conf);

   // Put up info server.
   int port = conf.getInt("hbase.thrift.info.port", 9095);
   if (port >= 0) {
     conf.setLong("startcode", System.currentTimeMillis());
     String a = conf.get("hbase.thrift.info.bindAddress", "0.0.0.0");
     infoServer = new InfoServer("thrift", a, port, false, conf);
     infoServer.setAttribute("hbase.conf", conf);
     infoServer.start();
   }
   serverRunner.run();
}
开发者ID:tenggyut，项目名称:HIndex，代码行数:32，代码来源:ThriftServer.java


示例5: putUpWebUI

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Puts up the webui.
 * @return Returns final port -- maybe different from what we started with.
 * @throws IOException
 */
private int putUpWebUI() throws IOException {
  int port = this.conf.getInt(HConstants.REGIONSERVER_INFO_PORT, 60030);
  // -1 is for disabling info server
  if (port < 0) return port;
  String addr = this.conf.get("hbase.regionserver.info.bindAddress", "0.0.0.0");
  // check if auto port bind enabled
  boolean auto = this.conf.getBoolean(HConstants.REGIONSERVER_INFO_PORT_AUTO,
      false);
  while (true) {
    try {
      this.infoServer = new InfoServer("regionserver", addr, port, false, this.conf);
      this.infoServer.addServlet("status", "/rs-status", RSStatusServlet.class);
      this.infoServer.addServlet("dump", "/dump", RSDumpServlet.class);
      this.infoServer.setAttribute(REGIONSERVER, this);
      this.infoServer.setAttribute(REGIONSERVER_CONF, conf);
      this.infoServer.start();
      break;
    } catch (BindException e) {
      if (!auto) {
        // auto bind disabled throw BindException
        LOG.error("Failed binding http info server to port: " + port);
        throw e;
      }
      // auto bind enabled, try to use another port
      LOG.info("Failed binding http info server to port: " + port);
      port++;
    }
  }
  return this.infoServer.getPort();
}
开发者ID:tenggyut，项目名称:HIndex，代码行数:36，代码来源:HRegionServer.java


示例6: putUpWebUI

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Puts up the webui.
 * @return Returns final port -- maybe different from what we started with.
 * @throws IOException
 */
private int putUpWebUI() throws IOException {
  int port = this.conf.getInt("hbase.regionserver.info.port", 60030);
  // -1 is for disabling info server
  if (port < 0) return port;
  String addr = this.conf.get("hbase.regionserver.info.bindAddress", "0.0.0.0");
  // check if auto port bind enabled
  boolean auto = this.conf.getBoolean(HConstants.REGIONSERVER_INFO_PORT_AUTO,
      false);
  while (true) {
    try {
      this.infoServer = new InfoServer("regionserver", addr, port, false, this.conf);
      this.infoServer.addServlet("status", "/rs-status", RSStatusServlet.class);
      this.infoServer.addServlet("dump", "/dump", RSDumpServlet.class);
      this.infoServer.setAttribute(REGIONSERVER, this);
      this.infoServer.setAttribute(REGIONSERVER_CONF, conf);
      this.infoServer.start();
      break;
    } catch (BindException e) {
      if (!auto) {
        // auto bind disabled throw BindException
        throw e;
      }
      // auto bind enabled, try to use another port
      LOG.info("Failed binding http info server to port: " + port);
      port++;
    }
  }
  return port;
}
开发者ID:wanhao，项目名称:IRIndex，代码行数:35，代码来源:HRegionServer.java


示例7: putUpWebUI

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Puts up the webui.
 * @return Returns final port -- maybe different from what we started with.
 * @throws IOException
 */
private int putUpWebUI() throws IOException {
  int port = this.conf.getInt("hbase.regionserver.info.port", 60030);
  // -1 is for disabling info server
  if (port < 0) return port;
  String addr = this.conf.get("hbase.regionserver.info.bindAddress", "0.0.0.0");
  // check if auto port bind enabled
  boolean auto = this.conf.getBoolean("hbase.regionserver.info.port.auto", false);
  while (true) {
    try {
      this.infoServer = new InfoServer("regionserver", addr, port, false, this.conf);
      this.infoServer.addServlet("status", "/rs-status", RSStatusServlet.class);
      this.infoServer.addServlet("dump", "/dump", RSDumpServlet.class);
      this.infoServer.setAttribute(REGIONSERVER, this);
      this.infoServer.start();
      break;
    } catch (BindException e) {
      if (!auto) {
        // auto bind disabled throw BindException
        throw e;
      }
      // auto bind enabled, try to use another port
      LOG.info("Failed binding http info server to port: " + port);
      port++;
    }
  }
  return port;
}
开发者ID:lifeng5042，项目名称:RStore，代码行数:33，代码来源:HRegionServer.java


示例8: putUpWebUI

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Puts up the webui.
 * @return Returns final port -- maybe different from what we started with.
 * @throws IOException
 */
private int putUpWebUI() throws IOException {
  int port = this.conf.getInt(HConstants.REGIONSERVER_INFO_PORT,
    HConstants.DEFAULT_REGIONSERVER_INFOPORT);
  // -1 is for disabling info server
  if (port < 0) return port;
  String addr = this.conf.get("hbase.regionserver.info.bindAddress", "0.0.0.0");
  // check if auto port bind enabled
  boolean auto = this.conf.getBoolean(HConstants.REGIONSERVER_INFO_PORT_AUTO,
      false);
  while (true) {
    try {
      this.infoServer = new InfoServer(getProcessName(), addr, port, false, this.conf);
      infoServer.addServlet("dump", "/dump", getDumpServlet());
      configureInfoServer();
      this.infoServer.start();
      break;
    } catch (BindException e) {
      if (!auto) {
        // auto bind disabled throw BindException
        LOG.error("Failed binding http info server to port: " + port);
        throw e;
      }
      // auto bind enabled, try to use another port
      LOG.info("Failed binding http info server to port: " + port);
      port++;
    }
  }
  port = this.infoServer.getPort();
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, port);
  int masterInfoPort = conf.getInt(HConstants.MASTER_INFO_PORT,
    HConstants.DEFAULT_MASTER_INFOPORT);
  conf.setInt("hbase.master.info.port.orig", masterInfoPort);
  conf.setInt(HConstants.MASTER_INFO_PORT, port);
  return port;
}
开发者ID:shenli-uiuc，项目名称:PyroDB，代码行数:41，代码来源:HRegionServer.java


示例9: putUpWebUI

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Puts up the webui.
 * @return Returns final port -- maybe different from what we started with.
 * @throws IOException
 */
private int putUpWebUI() throws IOException {
  int port = this.conf.getInt(HConstants.REGIONSERVER_INFO_PORT, 60030);
  // -1 is for disabling info server
  if (port < 0) return port;
  String addr = this.conf.get("hbase.regionserver.info.bindAddress", "0.0.0.0");
  // check if auto port bind enabled
  boolean auto = this.conf.getBoolean(HConstants.REGIONSERVER_INFO_PORT_AUTO,
      false);
  while (true) {
    try {
      this.infoServer = new InfoServer("regionserver", addr, port, false, this.conf);
      this.infoServer.addServlet("status", "/rs-status", RSStatusServlet.class);
      this.infoServer.addServlet("dump", "/dump", RSDumpServlet.class);
      this.infoServer.setAttribute(REGIONSERVER, this);
      this.infoServer.setAttribute(REGIONSERVER_CONF, conf);
      this.infoServer.start();
      break;
    } catch (BindException e) {
      if (!auto) {
        // auto bind disabled throw BindException
        LOG.error("Failed binding http info server to port: " + port);
        throw e;
      }
      // auto bind enabled, try to use another port
      LOG.info("Failed binding http info server to port: " + port);
      port++;
    }
  }
  return port;
}
开发者ID:cloud-software-foundation，项目名称:c5，代码行数:36，代码来源:HRegionServer.java


示例10: putUpWebUI

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Puts up the webui.
 * @return Returns final port -- maybe different from what we started with.
 * @throws IOException
 */
private int putUpWebUI() throws IOException {
  int port = this.conf.getInt(HConstants.REGIONSERVER_INFO_PORT, 60030);
  // -1 is for disabling info server
  if (port < 0) return port;
  String addr = this.conf.get("hbase.regionserver.info.bindAddress", "0.0.0.0");
  // check if auto port bind enabled
  boolean auto = this.conf.getBoolean(HConstants.REGIONSERVER_INFO_PORT_AUTO,
      false);
  while (true) {
    try {
      this.infoServer = new InfoServer("regionserver", addr, port, false, this.conf);
      this.infoServer.addServlet("status", "/rs-status", RSStatusServlet.class);
      this.infoServer.addServlet("dump", "/dump", RSDumpServlet.class);
      this.infoServer.setAttribute(REGIONSERVER, this);
      this.infoServer.setAttribute(REGIONSERVER_CONF, conf);
      this.infoServer.start();
      break;
    } catch (BindException e) {
      if (!auto) {
        // auto bind disabled throw BindException
        throw e;
      }
      // auto bind enabled, try to use another port
      LOG.info("Failed binding http info server to port: " + port);
      port++;
    }
  }
  return port;
}
开发者ID:daidong，项目名称:DominoHBase，代码行数:35，代码来源:HRegionServer.java


示例11: run

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/**
 * Main processing loop for the HMaster.
 * <ol>
 * <li>Block until becoming active master
 * <li>Finish initialization via finishInitialization(MonitoredTask)
 * <li>Enter loop until we are stopped
 * <li>Stop services and perform cleanup once stopped
 * </ol>
 */
@Override
public void run() {
  MonitoredTask startupStatus =
    TaskMonitor.get().createStatus("Master startup");
  startupStatus.setDescription("Master startup");
  masterStartTime = System.currentTimeMillis();
  try {
    this.registeredZKListenersBeforeRecovery = this.zooKeeper.getListeners();

    // Put up info server.
    int port = this.conf.getInt("hbase.master.info.port", 60010);
    if (port >= 0) {
      String a = this.conf.get("hbase.master.info.bindAddress", "0.0.0.0");
      this.infoServer = new InfoServer(MASTER, a, port, false, this.conf);
      this.infoServer.addServlet("status", "/master-status", MasterStatusServlet.class);
      this.infoServer.addServlet("dump", "/dump", MasterDumpServlet.class);
      this.infoServer.setAttribute(MASTER, this);
      this.infoServer.start();
    }

    /*
     * Block on becoming the active master.
     *
     * We race with other masters to write our address into ZooKeeper.  If we
     * succeed, we are the primary/active master and finish initialization.
     *
     * If we do not succeed, there is another active master and we should
     * now wait until it dies to try and become the next active master.  If we
     * do not succeed on our first attempt, this is no longer a cluster startup.
     */
    becomeActiveMaster(startupStatus);

    // We are either the active master or we were asked to shutdown
    if (!this.stopped) {
      finishInitialization(startupStatus, false);
      loop();
    }
  } catch (Throwable t) {
    // HBASE-5680: Likely hadoop23 vs hadoop 20.x/1.x incompatibility
    if (t instanceof NoClassDefFoundError &&
        t.getMessage().contains("org/apache/hadoop/hdfs/protocol/FSConstants$SafeModeAction")) {
        // improved error message for this special case
        abort("HBase is having a problem with its Hadoop jars.  You may need to "
            + "recompile HBase against Hadoop version "
            +  org.apache.hadoop.util.VersionInfo.getVersion()
            + " or change your hadoop jars to start properly", t);
    } else {
      abort("Unhandled exception. Starting shutdown.", t);
    }
  } finally {
    startupStatus.cleanup();

    stopChores();
    // Wait for all the remaining region servers to report in IFF we were
    // running a cluster shutdown AND we were NOT aborting.
    if (!this.abort && this.serverManager != null &&
        this.serverManager.isClusterShutdown()) {
      this.serverManager.letRegionServersShutdown();
    }
    stopServiceThreads();
    // Stop services started for both backup and active masters
    if (this.activeMasterManager != null) this.activeMasterManager.stop();
    if (this.catalogTracker != null) this.catalogTracker.stop();
    if (this.serverManager != null) this.serverManager.stop();
    if (this.assignmentManager != null) this.assignmentManager.stop();
    if (this.fileSystemManager != null) this.fileSystemManager.stop();
    if (this.snapshotManager != null) this.snapshotManager.stop("server shutting down.");
    this.zooKeeper.close();
  }
  LOG.info("HMaster main thread exiting");
}
开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:81，代码来源:HMaster.java


示例12: getInfoServer

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/** @return InfoServer object. Maybe null.*/
public InfoServer getInfoServer() {
  return this.infoServer;
}
开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:5，代码来源:HMaster.java


示例13: getInfoServer

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
/** @return the info server */
public InfoServer getInfoServer() {
  return infoServer;
}
开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:5，代码来源:HRegionServer.java


示例14: startServiceThreads

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
private void startServiceThreads() throws IOException{

  // Start the executor service pools
  this.executorService.startExecutorService(ExecutorType.MASTER_OPEN_REGION,
     conf.getInt("hbase.master.executor.openregion.threads", 5));
  this.executorService.startExecutorService(ExecutorType.MASTER_CLOSE_REGION,
     conf.getInt("hbase.master.executor.closeregion.threads", 5));
  this.executorService.startExecutorService(ExecutorType.MASTER_SERVER_OPERATIONS,
     conf.getInt("hbase.master.executor.serverops.threads", 3));
  this.executorService.startExecutorService(ExecutorType.MASTER_META_SERVER_OPERATIONS,
     conf.getInt("hbase.master.executor.serverops.threads", 5));
  
  // We depend on there being only one instance of this executor running
  // at a time.  To do concurrency, would need fencing of enable/disable of
  // tables.
  this.executorService.startExecutorService(ExecutorType.MASTER_TABLE_OPERATIONS, 1);

  // Start log cleaner thread
  String n = Thread.currentThread().getName();
  this.logCleaner =
     new LogCleaner(conf.getInt("hbase.master.cleaner.interval", 60 * 1000),
        this, conf, getMasterFileSystem().getFileSystem(),
        getMasterFileSystem().getOldLogDir());
        Threads.setDaemonThreadRunning(logCleaner.getThread(), n + ".oldLogCleaner");

  // Put up info server.
  int port = this.conf.getInt("hbase.master.info.port", 60010);
  if (port >= 0) {
    String a = this.conf.get("hbase.master.info.bindAddress", "0.0.0.0");
    this.infoServer = new InfoServer(MASTER, a, port, false, this.conf);
    this.infoServer.addServlet("status", "/master-status", MasterStatusServlet.class);
    this.infoServer.addServlet("dump", "/dump", MasterDumpServlet.class);
    this.infoServer.setAttribute(MASTER, this);
    this.infoServer.start();
   }
  
   // Start allowing requests to happen.
   this.rpcServer.openServer();
   if (LOG.isDebugEnabled()) {
     LOG.debug("Started service threads");
   }

 }
开发者ID:lifeng5042，项目名称:RStore，代码行数:44，代码来源:HMaster.java


示例15: startServiceThreads

import org.apache.hadoop.hbase.util.InfoServer; //导入依赖的package包/类
private void startServiceThreads() throws IOException{

   // Start the executor service pools
   this.executorService.startExecutorService(ExecutorType.MASTER_OPEN_REGION,
      conf.getInt("hbase.master.executor.openregion.threads", 5));
   this.executorService.startExecutorService(ExecutorType.MASTER_CLOSE_REGION,
      conf.getInt("hbase.master.executor.closeregion.threads", 5));
   this.executorService.startExecutorService(ExecutorType.MASTER_SERVER_OPERATIONS,
      conf.getInt("hbase.master.executor.serverops.threads", 3));
   this.executorService.startExecutorService(ExecutorType.MASTER_META_SERVER_OPERATIONS,
      conf.getInt("hbase.master.executor.serverops.threads", 5));

   // We depend on there being only one instance of this executor running
   // at a time.  To do concurrency, would need fencing of enable/disable of
   // tables.
   this.executorService.startExecutorService(ExecutorType.MASTER_TABLE_OPERATIONS, 1);

   // Start log cleaner thread
   String n = Thread.currentThread().getName();
   int cleanerInterval = conf.getInt("hbase.master.cleaner.interval", 60 * 1000);
   this.logCleaner =
      new LogCleaner(cleanerInterval,
         this, conf, getMasterFileSystem().getFileSystem(),
         getMasterFileSystem().getOldLogDir());
         Threads.setDaemonThreadRunning(logCleaner.getThread(), n + ".oldLogCleaner");

   //start the hfile archive cleaner thread
    Path archiveDir = HFileArchiveUtil.getArchivePath(conf);
    this.hfileCleaner = new HFileCleaner(cleanerInterval, this, conf, getMasterFileSystem()
        .getFileSystem(), archiveDir);
    Threads.setDaemonThreadRunning(hfileCleaner.getThread(), n + ".archivedHFileCleaner");

   // Put up info server.
   int port = this.conf.getInt("hbase.master.info.port", 60010);
   if (port >= 0) {
     String a = this.conf.get("hbase.master.info.bindAddress", "0.0.0.0");
     this.infoServer = new InfoServer(MASTER, a, port, false, this.conf);
     this.infoServer.addServlet("status", "/master-status", MasterStatusServlet.class);
     this.infoServer.addServlet("dump", "/dump", MasterDumpServlet.class);
     this.infoServer.setAttribute(MASTER, this);
     this.infoServer.start();
    }

   // Start the health checker
   if (this.healthCheckChore != null) {
     Threads.setDaemonThreadRunning(this.healthCheckChore.getThread(), n + ".healthChecker");
   }

    // Start allowing requests to happen.
    this.rpcServer.openServer();
    if (LOG.isDebugEnabled()) {
      LOG.debug("Started service threads");
    }

  }
开发者ID:zwqjsj0404，项目名称:HBase-Research，代码行数:56，代码来源:HMaster.java



注：本文中的org.apache.hadoop.hbase.util.InfoServer类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java Code类代码示例发布时间：2022-05-22
下一篇：
Java EternalExpiryPolicy类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap