本文整理了Java中com.dremio.dac.daemon.ZkServer
类的一些代码示例,展示了ZkServer
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkServer
类的具体详情如下:
包路径:com.dremio.dac.daemon.ZkServer
类名称:ZkServer
[英]ZooKeeper server service.
[中]ZooKeeper服务器服务。
代码示例来源:origin: dremio/dremio-oss
@Override
public Integer get() {
return bootstrapRegistry.lookup(ZkServer.class).getPort();
}} : null;
} else {
代码示例来源:origin: dremio/dremio-oss
@Override
public void start() throws Exception {
if (!FileUtils.deleteQuietly(storageDir)) {
logger.warn("Couldn't delete Zookeeper data directory");
}
init();
}
代码示例来源:origin: dremio/dremio-oss
Assume.assumeTrue(BaseTestServer.isMultinode());
try (Timer.TimedBlock b = Timer.time("BaseTestServer.@BeforeClass")) {
zkServer = new ZkServer(temporaryFolder.newFolder("zk").getAbsolutePath(), 21518, true);
zkServer.start();
.localPort(21515)
.httpPort(21516)
.zk("localhost:" + zkServer.getPort())
.with(DremioConfig.CLIENT_PORT_INT, 21517)
.with(DremioConfig.EMBEDDED_MASTER_ZK_ENABLED_BOOL, false)
.localPort(21525)
.httpPort(21526)
.zk("localhost:" + zkServer.getPort())
.with(DremioConfig.CLIENT_PORT_INT, 21527)
.with(DremioConfig.EMBEDDED_MASTER_ZK_ENABLED_BOOL, false)
.httpPort(21531)
.with(DremioConfig.CLIENT_PORT_INT, 21532)
.zk("localhost:" + zkServer.getPort()),
DremioTest.CLASSPATH_SCAN_RESULT);
代码示例来源:origin: dremio/dremio-oss
ZkServer zkServer = new ZkServer(
config.getString(DremioConfig.EMBEDDED_MASTER_ZK_ENABLED_PATH_STRING),
config.getInt(DremioConfig.EMBEDDED_MASTER_ZK_ENABLED_PORT_INT),
代码示例来源:origin: dremio/dremio-oss
int zkPort = masterDremioDaemon.getBindingProvider().lookup(ZkServer.class).getPort();
currentDremioDaemon = DACDaemon.newDremioDaemon(
DACConfig
内容来源于网络,如有侵权,请联系作者删除!