本文整理汇总了Java中org.apache.hadoop.hbase.ClusterManager.ServiceType类的典型用法代码示例。如果您正苦于以下问题：Java ServiceType类的具体用法？Java ServiceType怎么用？Java ServiceType使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ServiceType类属于org.apache.hadoop.hbase.ClusterManager包，在下文中一共展示了ServiceType类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: waitForServiceToStop
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
private void waitForServiceToStop(ServiceType service, ServerName serverName, long timeout)
throws IOException {
LOG.info("Waiting for service: " + service + " to stop: " + serverName.getServerName());
long start = System.currentTimeMillis();
while ((System.currentTimeMillis() - start) < timeout) {
if (!clusterManager.isRunning(service, serverName.getHostname(), serverName.getPort())) {
return;
}
Threads.sleep(100);
}
throw new IOException("did timeout waiting for service to stop:" + serverName);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:14，代码来源:DistributedHBaseCluster.java
示例2: waitForServiceToStart
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
private void waitForServiceToStart(ServiceType service, ServerName serverName, long timeout)
throws IOException {
LOG.info("Waiting for service: " + service + " to start: " + serverName.getServerName());
long start = System.currentTimeMillis();
while ((System.currentTimeMillis() - start) < timeout) {
if (clusterManager.isRunning(service, serverName.getHostname(), serverName.getPort())) {
return;
}
Threads.sleep(100);
}
throw new IOException("did timeout waiting for service to start:" + serverName);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:14，代码来源:DistributedHBaseCluster.java
示例3: waitForServiceToStop
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
private void waitForServiceToStop(ServiceType service, ServerName serverName, long timeout)
throws IOException {
LOG.info("Waiting service:" + service + " to stop: " + serverName.getServerName());
long start = System.currentTimeMillis();
while ((System.currentTimeMillis() - start) < timeout) {
if (!clusterManager.isRunning(service, serverName.getHostname())) {
return;
}
Threads.sleep(1000);
}
throw new IOException("did timeout waiting for service to stop:" + serverName);
}
开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:14，代码来源:DistributedHBaseCluster.java
示例4: killRegionServer
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void killRegionServer(ServerName serverName) throws IOException {
LOG.info("Aborting RS: " + serverName.getServerName());
killedRegionServers.add(serverName);
clusterManager.kill(ServiceType.HBASE_REGIONSERVER,
serverName.getHostname(), serverName.getPort());
}
开发者ID:apache，项目名称:hbase，代码行数:8，代码来源:DistributedHBaseCluster.java
示例5: startRegionServer
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void startRegionServer(String hostname, int port) throws IOException {
LOG.info("Starting RS on: " + hostname);
clusterManager.start(ServiceType.HBASE_REGIONSERVER, hostname, port);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:6，代码来源:DistributedHBaseCluster.java
示例6: killRegionServer
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void killRegionServer(ServerName serverName) throws IOException {
LOG.info("Aborting RS: " + serverName.getServerName());
clusterManager.kill(ServiceType.HBASE_REGIONSERVER,
serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:DistributedHBaseCluster.java
示例7: stopRegionServer
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void stopRegionServer(ServerName serverName) throws IOException {
LOG.info("Stopping RS: " + serverName.getServerName());
clusterManager.stop(ServiceType.HBASE_REGIONSERVER,
serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:DistributedHBaseCluster.java
示例8: waitForRegionServerToStop
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void waitForRegionServerToStop(ServerName serverName, long timeout) throws IOException {
waitForServiceToStop(ServiceType.HBASE_REGIONSERVER, serverName, timeout);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:5，代码来源:DistributedHBaseCluster.java
示例9: startZkNode
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void startZkNode(String hostname, int port) throws IOException {
LOG.info("Starting Zookeeper node on: " + hostname);
clusterManager.start(ServiceType.ZOOKEEPER_SERVER, hostname, port);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:6，代码来源:DistributedHBaseCluster.java
示例10: killZkNode
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void killZkNode(ServerName serverName) throws IOException {
LOG.info("Aborting Zookeeper node on: " + serverName.getServerName());
clusterManager.kill(ServiceType.ZOOKEEPER_SERVER,
serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:DistributedHBaseCluster.java
示例11: stopZkNode
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void stopZkNode(ServerName serverName) throws IOException {
LOG.info("Stopping Zookeeper node: " + serverName.getServerName());
clusterManager.stop(ServiceType.ZOOKEEPER_SERVER,
serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:DistributedHBaseCluster.java
示例12: waitForZkNodeToStart
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void waitForZkNodeToStart(ServerName serverName, long timeout) throws IOException {
waitForServiceToStart(ServiceType.ZOOKEEPER_SERVER, serverName, timeout);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:5，代码来源:DistributedHBaseCluster.java
示例13: waitForZkNodeToStop
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void waitForZkNodeToStop(ServerName serverName, long timeout) throws IOException {
waitForServiceToStop(ServiceType.ZOOKEEPER_SERVER, serverName, timeout);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:5，代码来源:DistributedHBaseCluster.java
示例14: startDataNode
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void startDataNode(ServerName serverName) throws IOException {
LOG.info("Starting data node on: " + serverName.getServerName());
clusterManager.start(ServiceType.HADOOP_DATANODE,
serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:DistributedHBaseCluster.java
示例15: killDataNode
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void killDataNode(ServerName serverName) throws IOException {
LOG.info("Aborting data node on: " + serverName.getServerName());
clusterManager.kill(ServiceType.HADOOP_DATANODE,
serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:DistributedHBaseCluster.java
示例16: stopDataNode
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void stopDataNode(ServerName serverName) throws IOException {
LOG.info("Stopping data node on: " + serverName.getServerName());
clusterManager.stop(ServiceType.HADOOP_DATANODE,
serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:7，代码来源:DistributedHBaseCluster.java
示例17: waitForDataNodeToStart
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void waitForDataNodeToStart(ServerName serverName, long timeout) throws IOException {
waitForServiceToStart(ServiceType.HADOOP_DATANODE, serverName, timeout);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:5，代码来源:DistributedHBaseCluster.java
示例18: waitForDataNodeToStop
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void waitForDataNodeToStop(ServerName serverName, long timeout) throws IOException {
waitForServiceToStop(ServiceType.HADOOP_DATANODE, serverName, timeout);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:5，代码来源:DistributedHBaseCluster.java
示例19: startMaster
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void startMaster(String hostname, int port) throws IOException {
LOG.info("Starting Master on: " + hostname + ":" + port);
clusterManager.start(ServiceType.HBASE_MASTER, hostname, port);
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:6，代码来源:DistributedHBaseCluster.java
示例20: killMaster
import org.apache.hadoop.hbase.ClusterManager.ServiceType; //导入依赖的package包/类
@Override
public void killMaster(ServerName serverName) throws IOException {
LOG.info("Aborting Master: " + serverName.getServerName());
clusterManager.kill(ServiceType.HBASE_MASTER, serverName.getHostname(), serverName.getPort());
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:6，代码来源:DistributedHBaseCluster.java
注：本文中的org.apache.hadoop.hbase.ClusterManager.ServiceType类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论