- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.ignite.spi.discovery.zk.internal.ZookeeperClient.needSplitNodeData()
方法的一些代码示例,展示了ZookeeperClient.needSplitNodeData()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperClient.needSplitNodeData()
方法的具体详情如下:
包路径:org.apache.ignite.spi.discovery.zk.internal.ZookeeperClient
类名称:ZookeeperClient
方法名:needSplitNodeData
暂无
代码示例来源:origin: apache/ignite
/**
* @param path Path to save.
* @param bytes Bytes to save.
* @param overhead Extra overhead.
* @return Parts count.
* @throws Exception If failed.
*/
private int saveData(String path, byte[] bytes, int overhead) throws Exception {
int dataForJoinedPartCnt = 1;
if (rtState.zkClient.needSplitNodeData(path, bytes, overhead)) {
dataForJoinedPartCnt = saveMultipleParts(rtState.zkClient,
path,
rtState.zkClient.splitNodeData(path, bytes, overhead));
}
else {
rtState.zkClient.createIfNeeded(multipartPathName(path, 0),
bytes,
PERSISTENT);
}
return dataForJoinedPartCnt;
}
代码示例来源:origin: apache/ignite
/**
* @param zkClient Client.
* @param msgBytes Marshalled message.
* @throws ZookeeperClientFailedException If connection to zk was lost.
* @throws InterruptedException If interrupted.
*/
private void saveCustomMessage(ZookeeperClient zkClient, byte[] msgBytes)
throws ZookeeperClientFailedException, InterruptedException
{
String prefix = UUID.randomUUID().toString();
int partCnt = 1;
int overhead = 10;
UUID locId = locNode.id();
String path = zkPaths.createCustomEventPath(prefix, locId, partCnt);
if (zkClient.needSplitNodeData(path, msgBytes, overhead)) {
List<byte[]> parts = zkClient.splitNodeData(path, msgBytes, overhead);
String partsBasePath = zkPaths.customEventPartsBasePath(prefix, locId);
saveMultipleParts(zkClient, partsBasePath, parts);
msgBytes = null;
partCnt = parts.size();
}
zkClient.createSequential(prefix,
zkPaths.customEvtsDir,
zkPaths.createCustomEventPath(prefix, locId, partCnt),
msgBytes,
CreateMode.PERSISTENT_SEQUENTIAL);
}
代码示例来源:origin: apache/ignite
/**
* @throws Exception If failed.
*/
@Test
public void testSaveLargeValue() throws Exception {
startZK(1);
final ZookeeperClient client = createClient(SES_TIMEOUT);
byte[] data = new byte[1024 * 1024];
String basePath = "/ignite";
assertTrue(client.needSplitNodeData(basePath, data, 2));
List<byte[]> parts = client.splitNodeData(basePath, data, 2);
assertTrue(parts.size() > 1);
ZooKeeper zk = client.zk();
for (int i = 0; i < parts.size(); i++) {
byte[] part = parts.get(i);
assertTrue(part.length > 0);
String path0 = basePath + ":" + i;
zk.create(path0, part, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}
}
代码示例来源:origin: apache/ignite
if (zkClient.needSplitNodeData(joinDataPath, joinDataBytes, OVERHEAD)) {
List<byte[]> parts = zkClient.splitNodeData(joinDataPath, joinDataBytes, OVERHEAD);
本文整理了Java中kafka.zookeeper.ZooKeeperClient.waitUntilConnected()方法的一些代码示例,展示了ZooKeeperClient.waitUntil
本文整理了Java中kafka.zookeeper.ZooKeeperClient.()方法的一些代码示例,展示了ZooKeeperClient.()的具体用法。这些代码示例主要来源于Github/S
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperClient.()方法的一些代码示例,展示了ZooKeeperClient.()的具体用法。这些代码示例
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperClient.registerExpirationHandler()方法的一些代码示例,展示了ZooKe
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperClient.digestCredentials()方法的一些代码示例,展示了ZooKeeperClie
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperClient.unregister()方法的一些代码示例,展示了ZooKeeperClient.unre
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperClient.get()方法的一些代码示例,展示了ZooKeeperClient.get()的具体用法。
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperClient.close()方法的一些代码示例,展示了ZooKeeperClient.close()的具
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperClient.shouldRetry()方法的一些代码示例,展示了ZooKeeperClient.sho
本文整理了Java中org.apache.bookkeeper.zookeeper.ZooKeeperClient.newBuilder()方法的一些代码示例,展示了ZooKeeperClient.n
本文整理了Java中org.apache.dubbo.remoting.zookeeper.ZookeeperClient.addStateListener()方法的一些代码示例,展示了Zookeep
本文整理了Java中org.apache.dubbo.remoting.zookeeper.ZookeeperClient.getChildren()方法的一些代码示例,展示了ZookeeperCli
本文整理了Java中org.apache.dubbo.remoting.zookeeper.ZookeeperClient.isConnected()方法的一些代码示例,展示了ZookeeperCli
本文整理了Java中org.apache.dubbo.remoting.zookeeper.ZookeeperClient.removeChildListener()方法的一些代码示例,展示了Zook
本文整理了Java中org.apache.dubbo.remoting.zookeeper.ZookeeperClient.addChildListener()方法的一些代码示例,展示了Zookeep
本文整理了Java中org.apache.dubbo.remoting.zookeeper.ZookeeperClient.delete()方法的一些代码示例,展示了ZookeeperClient.d
本文整理了Java中org.apache.dubbo.remoting.zookeeper.ZookeeperClient.create()方法的一些代码示例,展示了ZookeeperClient.c
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperClient.getNode()方法的一些代码示例,展示了ZooKe
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperClient.close()方法的一些代码示例,展示了ZooKeep
本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperClient.transaction()方法的一些代码示例,展示了Z
我是一名优秀的程序员,十分优秀!