本文整理了Java中org.apache.helix.manager.zk.ZkClient.create()方法的一些代码示例，展示了ZkClient.create()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkClient.create()方法的具体详情如下：
包路径：org.apache.helix.manager.zk.ZkClient
类名称：ZkClient
方法名：create

ZkClient.create介绍

暂无

代码示例

代码示例来源：origin: apache/helix

/**
 * Since ZkConnection session is shared in this ZkClient, do not create ephemeral node using a SharedZKClient.
 */
@Override
public String create(final String path, Object datat, final List<ACL> acl,
  final CreateMode mode) {
 if (mode.isEphemeral()) {
  throw new HelixException(
    "Create ephemeral nodes using a " + SharedZkClient.class.getSimpleName()
      + " ZkClient is not supported.");
 }
 return super.create(path, datat, acl, mode);
}

代码示例来源：origin: apache/helix

0);
Assert.assertEquals((long) beanServer.getAttribute(idealStatename, "WriteLatencyGauge.Max"), 0);
zkClient.create(TEST_PATH, TEST_DATA, CreateMode.PERSISTENT);
Assert.assertEquals((long) beanServer.getAttribute(rootname, "WriteCounter"), 1);
Assert.assertEquals((long) beanServer.getAttribute(rootname, "WriteBytesCounter"),

代码示例来源：origin: org.apache.helix/helix-core

public static void createOrReplace(ZkClient client, String path, final ZNRecord record,
  final boolean persistent) {
 int retryCount = 0;
 while (retryCount < RETRYLIMIT) {
  try {
   if (client.exists(path)) {
    DataUpdater<Object> updater = new DataUpdater<Object>() {
     @Override
     public Object update(Object currentData) {
      return record;
     }
    };
    client.updateDataSerialized(path, updater);
   } else {
    CreateMode mode = (persistent) ? CreateMode.PERSISTENT : CreateMode.EPHEMERAL;
    client.create(path, record, mode);
   }
   break;
  } catch (Exception e) {
   retryCount = retryCount + 1;
   logger.warn("Exception trying to createOrReplace " + path + " Exception:" + e.getMessage()
     + ". Will retry.");
  }
 }
}

代码示例来源：origin: org.apache.helix/helix-core

public static void createOrUpdate(ZkClient client, String path, final ZNRecord record,
  final boolean persistent, final boolean mergeOnUpdate) {
 int retryCount = 0;
 while (retryCount < RETRYLIMIT) {
  try {
   if (client.exists(path)) {
    DataUpdater<ZNRecord> updater = new DataUpdater<ZNRecord>() {
     @Override public ZNRecord update(ZNRecord currentData) {
      if (currentData != null && mergeOnUpdate) {
       currentData.update(record);
       return currentData;
      }
      return record;
     }
    };
    client.updateDataSerialized(path, updater);
   } else {
    CreateMode mode = (persistent) ? CreateMode.PERSISTENT : CreateMode.EPHEMERAL;
    client.create(path, record, mode);
   }
   break;
  } catch (Exception e) {
   retryCount = retryCount + 1;
   logger.warn("Exception trying to update " + path + " Exception:" + e.getMessage()
     + ". Will retry.");
  }
 }
}

代码示例来源：origin: org.apache.helix/helix-core

retry = false;
try {
 _zkClient.create(path, record, mode);
 result._pathCreated.add(path);

代码示例来源：origin: org.apache.helix/helix-core

ZNRecord value = new ZNRecord(record.getId());
 value.merge(record);
 client.create(path, value, mode);
} else {
 client.create(path, record, mode);

代码示例来源：origin: org.apache.helix/helix-core

ZNRecord newRecord = new ZNRecord(record.getId());
newRecord.merge(record);
client.create(path, null, mode);
client.create(path, null, mode);