- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.helix.manager.zk.ZKHelixAdmin.setResourceIdealState()
方法的一些代码示例,展示了ZKHelixAdmin.setResourceIdealState()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKHelixAdmin.setResourceIdealState()
方法的具体详情如下:
包路径:org.apache.helix.manager.zk.ZKHelixAdmin
类名称: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);
本文整理了Java中org.apache.helix.manager.zk.ZKHelixAdmin.setResourceIdealState()方法的一些代码示例,展示了ZKHelixAdmin.
我是一名优秀的程序员,十分优秀!