gpt4 book ai didi

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

转载 作者:知者 更新时间:2024-03-15 02:32:49 24 4
gpt4 key购买 nike

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

ZKHelixAdmin.setResourceIdealState介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-pinot

if (_fix) {
 LOGGER.info("Replacing IDEALSTATE for table " + tableName + " with " + nChanges + " changes");
 _helixAdmin.setResourceIdealState(_clusterName, tableName, idealState);
} else {
 LOGGER.info("Detected " + nChanges + " instances in " + fromState + " in table " + tableName);

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

@Override
public void enableBatchMessageMode(String clusterName, String resourceName, boolean enabled) {
 logger.info("{} batch message mode for resource {} in cluster {}.",
   enabled ? "Enable" : "Disable", resourceName, clusterName);
 // TODO: Change IdealState to ResourceConfig when configs are migrated to ResourceConfig
 IdealState idealState = getResourceIdealState(clusterName, resourceName);
 if (idealState == null) {
  throw new HelixException("Cluster " + clusterName + ", resource: " + resourceName
    + ", ideal-state does not exist");
 }
 idealState.setBatchMessageMode(enabled);
 setResourceIdealState(clusterName, resourceName, idealState);
}

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

@Override
public void enableBatchMessageMode(String clusterName, String resourceName,
  boolean enabled) {
 logger.info("{} batch message mode for resource {} in cluster {}.",
   enabled ? "Enable" : "Disable", resourceName, clusterName);
 // TODO: Change IdealState to ResourceConfig when configs are migrated to ResourceConfig
 IdealState idealState = getResourceIdealState(clusterName, resourceName);
 if (idealState == null) {
  throw new HelixException("Cluster " + clusterName + ", resource: " + resourceName
    + ", ideal-state does not exist");
 }
 idealState.setBatchMessageMode(enabled);
 setResourceIdealState(clusterName, resourceName, idealState);
}

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

@Override
public void addIdealState(String clusterName, String resourceName,
  String idealStateFile) throws IOException {
 logger.info("Add IdealState for resource {} to cluster {} by file name {}.", resourceName,
   clusterName, idealStateFile);
 ZNRecord idealStateRecord =
   (ZNRecord) (new ZNRecordSerializer().deserialize(readFile(idealStateFile)));
 if (idealStateRecord.getId() == null || !idealStateRecord.getId().equals(resourceName)) {
  throw new IllegalArgumentException("ideal state must have same id as resource name");
 }
 setResourceIdealState(clusterName, resourceName, new IdealState(idealStateRecord));
}

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

@Override
public void addIdealState(String clusterName, String resourceName, String idealStateFile)
  throws IOException {
 logger.info("Add IdealState for resource {} to cluster {} by file name {}.", resourceName,
   clusterName, idealStateFile);
 ZNRecord idealStateRecord =
   (ZNRecord) (new ZNRecordSerializer().deserialize(readFile(idealStateFile)));
 if (idealStateRecord.getId() == null || !idealStateRecord.getId().equals(resourceName)) {
  throw new IllegalArgumentException("ideal state must have same id as resource name");
 }
 setResourceIdealState(clusterName, resourceName, new IdealState(idealStateRecord));
}

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

setResourceIdealState(clusterName, newIdealStateRecord.getId(), newIdealState);

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

setResourceIdealState(clusterName, newIdealStateRecord.getId(), newIdealState);

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

setResourceIdealState(clusterName, resourceName, idealState);

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

setResourceIdealState(clusterName, resourceName, idealState);

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

_admin.setResourceIdealState(CLUSTER_NAME, TEST_DB2, idealState);

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

_admin.setResourceIdealState(CLUSTER_NAME, TEST_DB1, idealState);

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com