com.hazelcast.config.Config.getReplicatedMapConfigs()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(129)

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

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();
  }
}

相关文章

微信公众号

最新文章

更多

Config类方法