org.apache.helix.manager.zk.ZKUtil.createOrMerge()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-20 13:36:31 26 4

ZKUtil.createOrMerge(zkClient, splits[0], update, true, true);

ZKUtil.createOrMerge(zkClient, splits[0], update, true, true);

ZKUtil.createOrMerge(zkClient, zkPath, update, true, true);

ZKUtil.createOrMerge(zkClient, zkPath, update, true, true);

@Test()
public void testCreateOrMerge() {
 String path = PropertyPathBuilder.instanceConfig(clusterName, "id7");
 ZNRecord record = new ZNRecord("id7");
 List<String> list = Arrays.asList("value1");
 record.setListField("list", list);
 ZKUtil.createOrMerge(_gZkClient, path, record, true, true);
 record = _gZkClient.readData(path);
 AssertJUnit.assertEquals(list, record.getListField("list"));
 record = new ZNRecord("id7");
 List<String> list2 = Arrays.asList("value2");
 record.setListField("list", list2);
 ZKUtil.createOrMerge(_gZkClient, path, record, true, true);
 record = _gZkClient.readData(path);
 AssertJUnit.assertEquals(Arrays.asList("value1", "value2"), record.getListField("list"));
 Map<String, String> map = new HashMap<String, String>() {{put("k1", "v1");}};
 record.setMapField("map", map);
 ZKUtil.createOrMerge(_gZkClient, path, record, true, true);
 record = _gZkClient.readData(path);
 AssertJUnit.assertEquals(map, record.getMapField("map"));
 record = new ZNRecord("id7");
 Map<String, String> map2 = new HashMap<String, String>() {{put("k2", "v2");}};
 record.setMapField("map", map2);
 ZKUtil.createOrMerge(_gZkClient, path, record, true, true);
 record = _gZkClient.readData(path);
 AssertJUnit.assertEquals(new HashMap<String, String>() {{
  put("k1", "v1");
  put("k2", "v2");
 }}, record.getMapField("map"));
}

String path = PropertyPathBuilder.instanceConfig(clusterName, "id7");
ZNRecord record = new ZNRecord("id7");
ZKUtil.createOrMerge(_gZkClient, path, record, true, true);
record = _gZkClient.readData(path);
AssertJUnit.assertEquals("id7", record.getId());

26 4 0

• kafka.utils.ZkUtils.getReplicasForPartition()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getReplicasForPartition()方法的一些代码示例，展示了ZkUtils.getReplicasForPartition(

• kafka.utils.ZkUtils.getConsumerGroups()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getConsumerGroups()方法的一些代码示例，展示了ZkUtils.getConsumerGroups()的具体用法。这些代码示

• kafka.utils.ZkUtils.zkClient()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.zkClient()方法的一些代码示例，展示了ZkUtils.zkClient()的具体用法。这些代码示例主要来源于Github/Stack

• kafka.utils.ZkUtils.readDataMaybeNull()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.readDataMaybeNull()方法的一些代码示例，展示了ZkUtils.readDataMaybeNull()的具体用法。这些代码示

• kafka.utils.ZkUtils.updatePersistentPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.updatePersistentPath()方法的一些代码示例，展示了ZkUtils.updatePersistentPath()的具体用法

• kafka.utils.ZkUtils.getLeaderForPartition()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getLeaderForPartition()方法的一些代码示例，展示了ZkUtils.getLeaderForPartition()的具体

• kafka.utils.ZkUtils.formatAsReassignmentJson()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.formatAsReassignmentJson()方法的一些代码示例，展示了ZkUtils.formatAsReassignmentJso

• kafka.utils.ZkUtils.getPartitionsForTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionsForTopics()方法的一些代码示例，展示了ZkUtils.getPartitionsForTopics()的

• kafka.utils.ZkUtils.createZkClientAndConnection()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.createZkClientAndConnection()方法的一些代码示例，展示了ZkUtils.createZkClientAndCon

• kafka.utils.ZkUtils.ConsumersPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.ConsumersPath()方法的一些代码示例，展示了ZkUtils.ConsumersPath()的具体用法。这些代码示例主要来源于Gi

• kafka.utils.ZkUtils.getPartitionsBeingReassigned()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionsBeingReassigned()方法的一些代码示例，展示了ZkUtils.getPartitionsBeingR

• kafka.utils.ZkUtils.()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.()方法的一些代码示例，展示了ZkUtils.()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平

• kafka.utils.ZkUtils.apply()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.apply()方法的一些代码示例，展示了ZkUtils.apply()的具体用法。这些代码示例主要来源于Github/Stackoverfl

• kafka.utils.ZkUtils.BrokerIdsPath()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.BrokerIdsPath()方法的一些代码示例，展示了ZkUtils.BrokerIdsPath()的具体用法。这些代码示例主要来源于Gi

• kafka.utils.ZkUtils.getAllTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getAllTopics()方法的一些代码示例，展示了ZkUtils.getAllTopics()的具体用法。这些代码示例主要来源于Gith

• kafka.utils.ZkUtils.getAllBrokersInCluster()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getAllBrokersInCluster()方法的一些代码示例，展示了ZkUtils.getAllBrokersInCluster()的

• kafka.utils.ZkUtils.getPartitionAssignmentForTopics()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.getPartitionAssignmentForTopics()方法的一些代码示例，展示了ZkUtils.getPartitionAssi

• kafka.utils.ZkUtils.close()方法的使用及代码示例

  本文整理了Java中kafka.utils.ZkUtils.close()方法的一些代码示例，展示了ZkUtils.close()的具体用法。这些代码示例主要来源于Github/Stackoverfl

• org.apache.zookeeper.ZKUtil.listSubTreeBFS()方法的使用及代码示例

  本文整理了Java中org.apache.zookeeper.ZKUtil.listSubTreeBFS()方法的一些代码示例，展示了ZKUtil.listSubTreeBFS()的具体用法。这些代码

• com.facebook.zookeeper.ZkUtil.bytesToString()方法的使用及代码示例

  本文整理了Java中com.facebook.zookeeper.ZkUtil.bytesToString()方法的一些代码示例，展示了ZkUtil.bytesToString()的具体用法。这些代码