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

ZkHelixPropertyStore.update介绍

暂无

代码示例

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

/**
 * Add an user defined key-value pair data to workflow or job level
 * @param manager a connection to Helix
 * @param workflowJobResource the name of workflow or job
 * @param key the key of key-value pair
 * @param value the value of key-value pair
 */
protected static void addWorkflowJobUserContent(final HelixManager manager,
  String workflowJobResource, final String key, final String value) {
 String path = Joiner.on("/").join(TaskConstants.REBALANCER_CONTEXT_ROOT, workflowJobResource,
   USER_CONTENT_NODE);
 manager.getHelixPropertyStore().update(path, new DataUpdater<ZNRecord>() {
  @Override
  public ZNRecord update(ZNRecord znRecord) {
   znRecord.setSimpleField(key, value);
   return znRecord;
  }
 }, AccessOption.PERSISTENT);
}

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

/**
 * Add an user defined key-value pair data to task level
 * @param manager a connection to Helix
 * @param job the name of job
 * @param task the name of task
 * @param key the key of key-value pair
 * @param value the value of key-value pair
 */
protected static void addTaskUserContent(final HelixManager manager, String job,
  final String task, final String key, final String value) {
 String path =
   Joiner.on("/").join(TaskConstants.REBALANCER_CONTEXT_ROOT, job, USER_CONTENT_NODE);
 manager.getHelixPropertyStore().update(path, new DataUpdater<ZNRecord>() {
  @Override
  public ZNRecord update(ZNRecord znRecord) {
   if (znRecord.getMapField(task) == null) {
    znRecord.setMapField(task, new HashMap<String, String>());
   }
   znRecord.getMapField(task).put(key, value);
   return znRecord;
  }
 }, AccessOption.PERSISTENT);
}

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

@Override
public boolean update(String path, DataUpdater<T> updater, int options) {
 if (_fallbackStore == null) {
  return super.update(path, updater, options);
 } else {
  Stat stat = super.getStat(path, options);
  if (stat == null) {
   // create znode at new location with fallback-value
   T fallbackValue = _fallbackStore.get(path, null, options);
   boolean succeed = super.create(path, fallbackValue, AccessOption.PERSISTENT);
   if (!succeed) {
    LOG.error("Can't update " + path + " since there are concurrent updates");
    return false;
   }
  }
  return super.update(path, updater, options);
 }
}

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

@Override
public boolean update(String path, DataUpdater<T> updater, int options) {
 if (_fallbackStore == null) {
  return super.update(path, updater, options);
 } else {
  Stat stat = super.getStat(path, options);
  if (stat == null) {
   // create znode at new location with fallback-value
   T fallbackValue = _fallbackStore.get(path, null, options);
   boolean succeed = super.create(path, fallbackValue, AccessOption.PERSISTENT);
   if (!succeed) {
    LOG.error("Can't update " + path + " since there are concurrent updates");
    return false;
   }
  }
  return super.update(path, updater, options);
 }
}

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

final ChangeRecord lastRecordProcessed = checkpointFile.findLastRecordProcessed();
DataUpdater<ZNRecord> updater = new HighWaterMarkUpdater(message, lastRecordProcessed);
helixPropertyStore.update("/TRANSACTION_ID_METADATA" + "/" + message.getResourceName(),
  updater, AccessOption.PERSISTENT);
Stat stat = new Stat();

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

store.update(path, new DataUpdater<ZNRecord>() {

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

store.update(updatePath, new DataUpdater<ZNRecord>() {

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

store.update(updatePath, new DataUpdater<ZNRecord>() {