本文整理了Java中com.dremio.service.coordinator.zk.ZKClusterClient
类的一些代码示例,展示了ZKClusterClient
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKClusterClient
类的具体详情如下:
包路径:com.dremio.service.coordinator.zk.ZKClusterClient
类名称:ZKClusterClient
暂无
代码示例来源:origin: dremio/dremio-oss
public ZKClusterCoordinator(SabotConfig config, String connect) throws IOException {
this.zkClient = new ZKClusterClient(config, connect);
}
代码示例来源:origin: dremio/dremio-oss
@Override
public RegistrationHandle joinElection(String name, ElectionListener listener) {
return zkClient.joinElection(name, listener);
}
代码示例来源:origin: dremio/dremio-oss
@Override
public void start() throws Exception {
zkClient.start();
if (!closed) {
Thread.sleep(5);
for(Service service: Service.values()) {
ZKServiceSet serviceSet = zkClient.newServiceSet(service.name);
serviceSet.start();
serviceSets.put(service.role.name(), serviceSet);
}
logger.info("ZKClusterCoordination is up");
}
}
代码示例来源:origin: dremio/dremio-oss
@Test
public void test3ComponentsConnection() throws Exception {
assertNull(zooKeeperServer.getZKClient().exists("/dremio3/test/test-cluster-id", false));
try(ZKClusterClient client = new ZKClusterClient(
DEFAULT_SABOT_CONFIG,
String.format("%s/dremio3/test/test-cluster-id", zooKeeperServer.getConnectString()))
) {
client.start();
ZKServiceSet serviceSet = client.newServiceSet("coordinator");
serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
Stat stat = zooKeeperServer.getZKClient().exists("/dremio3/test/test-cluster-id/coordinator", false);
assertNotNull(stat);
assertEquals(1, stat.getNumChildren());
}
}
代码示例来源:origin: dremio/dremio-oss
try(ZKClusterClient client = new ZKClusterClient(
DEFAULT_SABOT_CONFIG,
String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))
) {
client.start();
RegistrationHandle node1 = client.joinElection("test-election", new ElectionListener() {
RegistrationHandle node2 = client.joinElection("test-election", new ElectionListener() {
@Override
public void onElected() {
代码示例来源:origin: dremio/dremio-oss
@Override
public synchronized ServiceSet getOrCreateServiceSet(final String serviceName) {
return serviceSets.computeIfAbsent(serviceName, s -> {
final ZKServiceSet newServiceSet = zkClient.newServiceSet(serviceName);
try {
newServiceSet.start();
} catch (Exception e) {
throw new RuntimeException(String.format("Unable to start %s service in Zookeeper", serviceName), e);
}
return newServiceSet;
});
}
代码示例来源:origin: dremio/dremio-oss
/**
* Kill the given ZK session
*
* @param clusterCoordinator the cluster coordinator owning the session
*/
public static void kill(ZKClusterCoordinator clusterCoordinator) throws Exception {
KillSession.kill(clusterCoordinator.getZkClient().getZooKeeperClient(), clusterCoordinator.getZkClient().getConnectionString());
}
代码示例来源:origin: dremio/dremio-oss
@Override
public DistributedSemaphore getSemaphore(String name, int maximumLeases) {
return zkClient.getSemaphore(name, maximumLeases);
}
代码示例来源:origin: dremio/dremio-oss
curator.getConnectionStateListenable().addListener(new ConnectionLogger());
curator.start();
discovery = newDiscovery(clusterId);
代码示例来源:origin: dremio/dremio-oss
@Test
public void test1ComponentConnection() throws Exception {
assertNull(zooKeeperServer.getZKClient().exists("/dremio1", false));
try(ZKClusterClient client = new ZKClusterClient(
DEFAULT_SABOT_CONFIG,
String.format("%s/dremio1", zooKeeperServer.getConnectString()))
) {
client.start();
ZKServiceSet serviceSet = client.newServiceSet("coordinator");
serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
Stat stat = zooKeeperServer.getZKClient().exists("/dremio1/coordinator", false);
assertNotNull(stat);
assertEquals(1, stat.getNumChildren());
}
}
代码示例来源:origin: dremio/dremio-oss
@Test
public void testElectionDisconnection() throws Exception {
final CountDownLatch elected = new CountDownLatch(1);
final CountDownLatch cancelled = new CountDownLatch(1);
try(ZKClusterClient client = new ZKClusterClient(
DEFAULT_SABOT_CONFIG
.withValue(ClusterCoordinator.Options.ZK_ELECTION_POLLING, ConfigValueFactory.fromAnyRef("20ms"))
.withValue(ClusterCoordinator.Options.ZK_ELECTION_TIMEOUT, ConfigValueFactory.fromAnyRef("100ms")),
String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))
) {
client.start();
RegistrationHandle node1 = client.joinElection("test-election", new ElectionListener() {
@Override
public void onElected() {
elected.countDown();
}
@Override
public void onCancelled() {
cancelled.countDown();
}
});
assertTrue("No election happened", elected.await(5, TimeUnit.SECONDS));
// Kill the server to force disconnection
zooKeeperServer.closeServer();
assertTrue("Node was not notified about cancellation", cancelled.await(5, TimeUnit.SECONDS));
}
}
代码示例来源:origin: dremio/dremio-oss
@Test
public void test2ComponentsConnection() throws Exception {
assertNull(zooKeeperServer.getZKClient().exists("/dremio2/test-cluster-id", false));
try(ZKClusterClient client = new ZKClusterClient(
DEFAULT_SABOT_CONFIG,
String.format("%s/dremio2/test-cluster-id", zooKeeperServer.getConnectString()))
) {
client.start();
ZKServiceSet serviceSet = client.newServiceSet("coordinator");
serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
Stat stat = zooKeeperServer.getZKClient().exists("/dremio2/test-cluster-id/coordinator", false);
assertNotNull(stat);
assertEquals(1, stat.getNumChildren());
}
}
代码示例来源:origin: dremio/dremio-oss
final CountDownLatch reconnected = new CountDownLatch(1);
try(ZKClusterClient client = new ZKClusterClient(
DEFAULT_SABOT_CONFIG
.withValue(ClusterCoordinator.Options.ZK_ELECTION_POLLING, ConfigValueFactory.fromAnyRef("250ms"))
String.format("%s/dremio/test/test-cluster-id", zooKeeperServer.getConnectString()))
) {
client.start();
RegistrationHandle node1 = client.joinElection("test-election", new ZKElectionListener() {
代码示例来源:origin: dremio/dremio-oss
public ZKClusterCoordinator(SabotConfig config, Provider<Integer> localPort) throws IOException {
this.zkClient = new ZKClusterClient(config, localPort);
}
代码示例来源:origin: dremio/dremio-oss
@Test
public void testDefaultConnection() throws Exception {
// Default root from sabot-module.conf
assertNull(zooKeeperServer.getZKClient().exists("/dremio/test-path", false));
final SabotConfig config = DEFAULT_SABOT_CONFIG
.withValue(ZK_ROOT, ConfigValueFactory.fromAnyRef("dremio/test-path"))
.withValue(CLUSTER_ID, ConfigValueFactory.fromAnyRef("test-cluster-id"));
try(ZKClusterClient client = new ZKClusterClient(config, new Provider<Integer>() {
@Override
public Integer get() {
return zooKeeperServer.getPort();
}
})) {
client.start();
ZKServiceSet serviceSet = client.newServiceSet("coordinator");
serviceSet.register(NodeEndpoint.newBuilder().setAddress("foo").build());
Stat stat = zooKeeperServer.getZKClient().exists("/dremio/test-path/test-cluster-id/coordinator", false);
assertNotNull(stat);
assertEquals(1, stat.getNumChildren());
}
}
内容来源于网络,如有侵权,请联系作者删除!