本文整理了Java中org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster.getZooKeeperServers()
方法的一些代码示例,展示了MiniZooKeeperCluster.getZooKeeperServers()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MiniZooKeeperCluster.getZooKeeperServers()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster
类名称:MiniZooKeeperCluster
方法名:getZooKeeperServers
暂无
代码示例来源:origin: apache/hbase
@Test
public void testSessionExpire() throws Exception {
assertArrayEquals(DATA, RO_ZK.get(PATH).get());
ZooKeeper zk = RO_ZK.zookeeper;
long sessionId = zk.getSessionId();
UTIL.getZkCluster().getZooKeeperServers().get(0).closeSession(sessionId);
// should not reach keep alive so still the same instance
assertSame(zk, RO_ZK.zookeeper);
byte[] got = RO_ZK.get(PATH).get();
assertArrayEquals(DATA, got);
assertNotNull(RO_ZK.zookeeper);
assertNotSame(zk, RO_ZK.zookeeper);
assertNotEquals(sessionId, RO_ZK.zookeeper.getSessionId());
}
代码示例来源:origin: com.aliyun.hbase/alihbase-zookeeper
@Test
public void testSessionExpire() throws Exception {
assertArrayEquals(DATA, RO_ZK.get(PATH).get());
ZooKeeper zk = RO_ZK.zookeeper;
long sessionId = zk.getSessionId();
UTIL.getZkCluster().getZooKeeperServers().get(0).closeSession(sessionId);
// should not reach keep alive so still the same instance
assertSame(zk, RO_ZK.zookeeper);
byte[] got = RO_ZK.get(PATH).get();
assertArrayEquals(DATA, got);
assertNotNull(RO_ZK.zookeeper);
assertNotSame(zk, RO_ZK.zookeeper);
assertNotEquals(sessionId, RO_ZK.zookeeper.getSessionId());
}
代码示例来源:origin: org.apache.hbase/hbase-zookeeper
@Test
public void testSessionExpire() throws Exception {
assertArrayEquals(DATA, RO_ZK.get(PATH).get());
ZooKeeper zk = RO_ZK.zookeeper;
long sessionId = zk.getSessionId();
UTIL.getZkCluster().getZooKeeperServers().get(0).closeSession(sessionId);
// should not reach keep alive so still the same instance
assertSame(zk, RO_ZK.zookeeper);
byte[] got = RO_ZK.get(PATH).get();
assertArrayEquals(DATA, got);
assertNotNull(RO_ZK.zookeeper);
assertNotSame(zk, RO_ZK.zookeeper);
assertNotEquals(sessionId, RO_ZK.zookeeper.getSessionId());
}
内容来源于网络,如有侵权,请联系作者删除!