本文整理了Java中com.liveramp.hank.zookeeper.ZooKeeperPlus.setData()
方法的一些代码示例,展示了ZooKeeperPlus.setData()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperPlus.setData()
方法的具体详情如下:
包路径:com.liveramp.hank.zookeeper.ZooKeeperPlus
类名称:ZooKeeperPlus
方法名:setData
暂无
代码示例来源:origin: LiveRamp/hank
public void setString(String path, String value) throws KeeperException, InterruptedException {
setData(path, value.getBytes(), -1);
}
代码示例来源:origin: LiveRamp/hank
public void setInt(String path, int nextVersion) throws KeeperException, InterruptedException {
setData(path, (Integer.toString(nextVersion)).getBytes(), -1);
}
代码示例来源:origin: LiveRamp/hank
public void set(T v) throws KeeperException, InterruptedException {
zk.setData(nodePath, encode(v), -1);
}
代码示例来源:origin: LiveRamp/hank
public void setOrCreate(String path, String value, CreateMode createMode) throws KeeperException, InterruptedException {
if (exists(path, false) == null) {
create(path, value.getBytes(), DEFAULT_ACL, createMode);
} else {
setData(path, value.getBytes(), -1);
}
}
代码示例来源:origin: LiveRamp/hank
private int getNextDomainId() throws KeeperException, InterruptedException {
final String domainIdCounterPath = ZkPath.append(domainsRoot, KEY_DOMAIN_ID_COUNTER);
if (zk.exists(domainIdCounterPath, false) == null) {
zk.create(domainIdCounterPath, Integer.toString(1).getBytes());
return 1;
}
while (true) {
final Stat stat = new Stat();
final byte[] data = zk.getData(domainIdCounterPath, false, stat);
int lastVersionNumber = Integer.parseInt(new String(data));
try {
lastVersionNumber++;
zk.setData(domainIdCounterPath, Integer.toString(lastVersionNumber).getBytes(), stat.getVersion());
return lastVersionNumber;
} catch (KeeperException.BadVersionException e) {
if (LOG.isDebugEnabled()) {
LOG.debug("Tried to set the domain id counter to " + lastVersionNumber + " but was preempted by another writer. Retrying.");
}
}
}
}
代码示例来源:origin: LiveRamp/hank
} else if (command.equals("null")) {
System.out.println("Setting node to null: " + argument);
zkCli.zk.setData(argument, null, -1);
} else if (command.equals("count")) {
System.out.println("Counting the number of descendants in: " + argument);
代码示例来源:origin: LiveRamp/hank
public void update(WatchedNodeUpdater<T> updater) throws InterruptedException, KeeperException {
ExponentialBackoff backoff = new ExponentialBackoff();
while (true) {
try {
synchronized (this) {
zk.setData(nodePath, encode(updater.update(value)), stat.getVersion());
}
} catch (KeeperException.BadVersionException e) {
// If we did not update from the latest version, backoff and retry.
if (LOG.isDebugEnabled()) {
LOG.debug("Did not have latest version to update node " + nodePath + ". Backing off for " + backoff.getBackoffMs() + " ms");
}
backoff.backoff();
continue;
}
break;
}
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testIt() throws Exception {
final ZooKeeperPlus zk = getZk();
final String nodePath = ZkPath.append(getRoot(), "watchedNode");
zk.create(nodePath, "1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
final WatchedLong wl = new WatchedLong(zk, nodePath);
assertEquals(Long.valueOf(1), wl.get());
zk.setData(nodePath, "55".getBytes(), -1);
WaitUntil.orDie(() -> Long.valueOf(55).equals(wl.get()));
assertEquals(Long.valueOf(55), wl.get());
zk.setData(nodePath, null, -1);
WaitUntil.orDie(() -> wl.get() == null);
assertNull(wl.get());
final WatchedLong wl2 = new WatchedLong(zk, nodePath);
WaitUntil.orDie(() -> null == wl2.get());
assertNull(wl2.get());
wl2.set(22L);
WaitUntil.orDie(() -> Long.valueOf(22).equals(wl2.get()) && Long.valueOf(22).equals(wl.get()));
assertEquals(Long.valueOf(22), wl2.get());
assertEquals(Long.valueOf(22), wl.get());
}
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testIt() throws Exception {
final ZooKeeperPlus zk = getZk();
final String nodePath = ZkPath.append(getRoot(), "watchedNode");
zk.create(nodePath, "1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
final WatchedInt wi = new WatchedInt(zk, nodePath, true);
assertEquals(Integer.valueOf(1), wi.get());
zk.setData(nodePath, "55".getBytes(), -1);
WaitUntil.orDie(() -> {
Integer v = wi.get();
return v != null && v == 55;
});
assertEquals(Integer.valueOf(55), wi.get());
zk.setData(nodePath, null, -1);
WaitUntil.orDie(() -> wi.get() == null);
assertNull(wi.get());
final WatchedInt wi2 = new WatchedInt(zk, nodePath, true);
WaitUntil.orDie(() -> wi2.get() == null);
assertNull(wi2.get());
wi2.set(22);
WaitUntil.orDie(() -> {
Integer v = wi.get();
Integer v2 = wi2.get();
return v2 != null && v2 == 22 && v != null && v == 22;
});
assertEquals(Integer.valueOf(22), wi2.get());
assertEquals(Integer.valueOf(22), wi.get());
}
内容来源于网络,如有侵权,请联系作者删除!