本文整理了Java中com.hazelcast.config.Config.getReplicatedMapConfigs()
方法的一些代码示例,展示了Config.getReplicatedMapConfigs()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Config.getReplicatedMapConfigs()
方法的具体详情如下:
包路径:com.hazelcast.config.Config
类名称:Config
方法名:getReplicatedMapConfigs
[英]Returns the map of com.hazelcast.core.ReplicatedMapconfigurations, mapped by config name. The config name may be a pattern with which the configuration was initially obtained.
[中]返回com的映射。黑泽尔卡斯特。果心ReplicatedMapconfigurations,按配置名称映射。配置名称可能是最初获取配置时使用的模式。
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public Map<String, ReplicatedMapConfig> getStaticConfigs(@Nonnull Config staticConfig) {
return staticConfig.getReplicatedMapConfigs();
}
});
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public Map<String, ReplicatedMapConfig> getStaticConfigs(@Nonnull Config staticConfig) {
return staticConfig.getReplicatedMapConfigs();
}
});
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public Map<String, ReplicatedMapConfig> getReplicatedMapConfigs() {
Map<String, ReplicatedMapConfig> staticConfigs = staticConfig.getReplicatedMapConfigs();
Map<String, ReplicatedMapConfig> dynamicConfigs = configurationService.getReplicatedMapConfigs();
return aggregate(staticConfigs, dynamicConfigs);
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public Map<String, ReplicatedMapConfig> getReplicatedMapConfigs() {
Map<String, ReplicatedMapConfig> staticConfigs = staticConfig.getReplicatedMapConfigs();
Map<String, ReplicatedMapConfig> dynamicConfigs = configurationService.getReplicatedMapConfigs();
return aggregate(staticConfigs, dynamicConfigs);
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public Config addReplicatedMapConfig(ReplicatedMapConfig replicatedMapConfig) {
boolean staticConfigDoesNotExist = checkStaticConfigDoesNotExist(staticConfig.getReplicatedMapConfigs(),
replicatedMapConfig.getName(), replicatedMapConfig);
if (staticConfigDoesNotExist) {
configurationService.broadcastConfig(replicatedMapConfig);
}
return this;
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public Config addReplicatedMapConfig(ReplicatedMapConfig replicatedMapConfig) {
boolean staticConfigDoesNotExist = checkStaticConfigDoesNotExist(staticConfig.getReplicatedMapConfigs(),
replicatedMapConfig.getName(), replicatedMapConfig);
if (staticConfigDoesNotExist) {
configurationService.broadcastConfig(replicatedMapConfig);
}
return this;
}
代码示例来源:origin: hazelcast/hazelcast-jet
@SuppressWarnings("deprecation")
private static void replicatedMapConfigXmlGenerator(XmlGenerator gen, Config config) {
for (ReplicatedMapConfig r : config.getReplicatedMapConfigs().values()) {
MergePolicyConfig mergePolicyConfig = r.getMergePolicyConfig();
gen.open("replicatedmap", "name", r.getName())
.node("in-memory-format", r.getInMemoryFormat())
.node("concurrency-level", r.getConcurrencyLevel())
.node("replication-delay-millis", r.getReplicationDelayMillis())
.node("async-fillup", r.isAsyncFillup())
.node("statistics-enabled", r.isStatisticsEnabled())
.node("quorum-ref", r.getQuorumName())
.node("merge-policy", mergePolicyConfig.getPolicy(), "batch-size", mergePolicyConfig.getBatchSize());
if (!r.getListenerConfigs().isEmpty()) {
gen.open("entry-listeners");
for (ListenerConfig lc : r.getListenerConfigs()) {
gen.node("entry-listener", classNameOrImplClass(lc.getClassName(), lc.getImplementation()),
"include-value", lc.isIncludeValue(),
"local", lc.isLocal());
}
gen.close();
}
gen.close();
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@SuppressWarnings("deprecation")
private static void replicatedMapConfigXmlGenerator(XmlGenerator gen, Config config) {
for (ReplicatedMapConfig r : config.getReplicatedMapConfigs().values()) {
MergePolicyConfig mergePolicyConfig = r.getMergePolicyConfig();
gen.open("replicatedmap", "name", r.getName())
.node("in-memory-format", r.getInMemoryFormat())
.node("concurrency-level", r.getConcurrencyLevel())
.node("replication-delay-millis", r.getReplicationDelayMillis())
.node("async-fillup", r.isAsyncFillup())
.node("statistics-enabled", r.isStatisticsEnabled())
.node("quorum-ref", r.getQuorumName())
.node("merge-policy", mergePolicyConfig.getPolicy(), "batch-size", mergePolicyConfig.getBatchSize());
if (!r.getListenerConfigs().isEmpty()) {
gen.open("entry-listeners");
for (ListenerConfig lc : r.getListenerConfigs()) {
gen.node("entry-listener", classNameOrImplClass(lc.getClassName(), lc.getImplementation()),
"include-value", lc.isIncludeValue(),
"local", lc.isLocal());
}
gen.close();
}
gen.close();
}
}
内容来源于网络,如有侵权,请联系作者删除!