org.apache.pinot.common.utils.ZkStarter.stopLocalZkServer()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(85)

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

ZkStarter.stopLocalZkServer介绍

[英]Stops a local Zk instance, deleting its data directory
[中]停止本地Zk实例,删除其数据目录

代码示例

代码示例来源:origin: apache/incubator-pinot

/**
 * Stops a local Zk instance, deleting its data directory
 */
public static void stopLocalZkServer(final ZookeeperInstance instance) {
 stopLocalZkServer(instance, true);
}

代码示例来源:origin: apache/incubator-pinot

public boolean stop() {
 ZkStarter.stopLocalZkServer(_zookeeperInstance);
 return true;
}

代码示例来源:origin: apache/incubator-pinot

protected void stopZk() {
 try {
  ZkStarter.stopLocalZkServer(_zookeeperInstance);
 } catch (Exception e) {
  // Swallow exceptions
 }
}

代码示例来源:origin: apache/incubator-pinot

@Override
 public void run() {
  try {
   printStatus(Color.GREEN, "***** Shutting down hybrid quick start *****");
   stream.shutdown();
   Thread.sleep(2000);
   runner.stop();
   KafkaStarterUtils.stopServer(_kafkaStarter);
   ZkStarter.stopLocalZkServer(_zookeeperInstance);
   FileUtils.deleteDirectory(_offlineQuickStartDataDir);
   FileUtils.deleteDirectory(_realtimeQuickStartDataDir);
  } catch (Exception e) {
   e.printStackTrace();
  }
 }
});

代码示例来源:origin: apache/incubator-pinot

@Override
 public void run() {
  try {
   printStatus(Color.GREEN, "***** Shutting down realtime quick start *****");
   meetupRSVPProvider.stopPublishing();
   runner.stop();
   KafkaStarterUtils.stopServer(kafkaStarter);
   ZkStarter.stopLocalZkServer(zookeeperInstance);
   FileUtils.deleteDirectory(quickStartDataDir);
  } catch (Exception e) {
   e.printStackTrace();
  }
 }
});

代码示例来源:origin: apache/incubator-pinot

@AfterClass
 public void tearDown() {
  _pinotHelixResourceManager.stop();
  _zkClient.close();
  ZkStarter.stopLocalZkServer(_zookeeperInstance);
 }
}

代码示例来源:origin: apache/incubator-pinot

@AfterClass
public void shutDown() {
 _pinotHelixResourceManager.stop();
 _zkClient.close();
 ZkStarter.stopLocalZkServer(_zookeeperInstance);
}

代码示例来源:origin: apache/incubator-pinot

@AfterTest
public void afterTest() {
 _zkClient.close();
 ZkStarter.stopLocalZkServer(_zookeeperInstance);
}

代码示例来源:origin: apache/incubator-pinot

@AfterTest
public void afterTest() {
 if (_helixManager instanceof FakeHelixManager) {
  ((FakeHelixManager) _helixManager).closeZkClient();
 }
 ZkStarter.stopLocalZkServer(_zookeeperInstance);
}

代码示例来源:origin: apache/incubator-pinot

@AfterTest
public void tearDown() {
 _pinotResourceManager.stop();
 _zkClient.close();
 ZkStarter.stopLocalZkServer(_zookeeperInstance);
}

代码示例来源:origin: apache/incubator-pinot

@AfterTest
public void tearDown() {
 _pinotHelixResourceManager.stop();
 _zkClient.close();
 ZkStarter.stopLocalZkServer(_zookeeperInstance);
}

相关文章