org.apache.samza.util.Util.rewriteConfig()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(6.3k)|赞(0)|评价(0)|浏览(172)

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

Util.rewriteConfig介绍

暂无

代码示例

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

  1. static Config mergeConfig(Map<String, String> originalConfig, Map<String, String> generatedConfig) {
  2.  Map<String, String> mergedConfig = new HashMap<>(generatedConfig);
  3.  originalConfig.forEach((k, v) -> {
  4.    if (generatedConfig.containsKey(k) && !Objects.equals(generatedConfig.get(k), v)) {
  5.     LOG.info("Replacing generated config for key: {} value: {} with original config value: {}", k, generatedConfig.get(k), v);
  6.    }
  7.    mergedConfig.put(k, v);
  8.   });
  9.  return Util.rewriteConfig(new MapConfig(mergedConfig));
  10. }

代码示例来源：origin: org.apache.samza/samza-core_2.10

  1. static Config mergeConfig(Map<String, String> originalConfig, Map<String, String> generatedConfig) {
  2.  Map<String, String> mergedConfig = new HashMap<>(generatedConfig);
  3.  originalConfig.forEach((k, v) -> {
  4.    if (generatedConfig.containsKey(k) && !Objects.equals(generatedConfig.get(k), v)) {
  5.     LOG.info("Replacing generated config for key: {} value: {} with original config value: {}", k, generatedConfig.get(k), v);
  6.    }
  7.    mergedConfig.put(k, v);
  8.   });
  9.  return Util.rewriteConfig(new MapConfig(mergedConfig));
  10. }

代码示例来源：origin: org.apache.samza/samza-core_2.12

  1. static Config mergeConfig(Map<String, String> originalConfig, Map<String, String> generatedConfig) {
  2.  Map<String, String> mergedConfig = new HashMap<>(generatedConfig);
  3.  originalConfig.forEach((k, v) -> {
  4.    if (generatedConfig.containsKey(k) && !Objects.equals(generatedConfig.get(k), v)) {
  5.     LOG.info("Replacing generated config for key: {} value: {} with original config value: {}", k, generatedConfig.get(k), v);
  6.    }
  7.    mergedConfig.put(k, v);
  8.   });
  9.  return Util.rewriteConfig(new MapConfig(mergedConfig));
  10. }

代码示例来源：origin: org.apache.samza/samza-core_2.11

  1. static Config mergeConfig(Map<String, String> originalConfig, Map<String, String> generatedConfig) {
  2.  Map<String, String> mergedConfig = new HashMap<>(generatedConfig);
  3.  originalConfig.forEach((k, v) -> {
  4.    if (generatedConfig.containsKey(k) && !Objects.equals(generatedConfig.get(k), v)) {
  5.     LOG.info("Replacing generated config for key: {} value: {} with original config value: {}", k, generatedConfig.get(k), v);
  6.    }
  7.    mergedConfig.put(k, v);
  8.   });
  9.  return Util.rewriteConfig(new MapConfig(mergedConfig));
  10. }

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

  1. static Config mergeConfig(Map<String, String> originalConfig, Map<String, String> generatedConfig) {
  2.  Map<String, String> mergedConfig = new HashMap<>(generatedConfig);
  3.  originalConfig.forEach((k, v) -> {
  4.    if (generatedConfig.containsKey(k) && !Objects.equals(generatedConfig.get(k), v)) {
  5.     LOG.info("Replacing generated config for key: {} value: {} with original config value: {}", k, generatedConfig.get(k), v);
  6.    }
  7.    mergedConfig.put(k, v);
  8.   });
  9.  return Util.rewriteConfig(new MapConfig(mergedConfig));
  10. }

代码示例来源：origin: org.apache.samza/samza-core_2.10

  1. public static void main(String[] args) throws Exception {
  2.   ApplicationRunnerCommandLine cmdLine = new ApplicationRunnerCommandLine();
  3.   OptionSet options = cmdLine.parser().parse(args);
  4.   Config orgConfig = cmdLine.loadConfig(options);
  5.   Config config = Util.rewriteConfig(orgConfig);
  6.   ApplicationRunnerOperation op = cmdLine.getOperation(options);
  8.   ApplicationRunner appRunner =
  9.     ApplicationRunners.getApplicationRunner(ApplicationUtil.fromConfig(config), config);
  11.   switch (op) {
  12.    case RUN:
  13.     appRunner.run();
  14.     break;
  15.    case KILL:
  16.     appRunner.kill();
  17.     break;
  18.    case STATUS:
  19.     System.out.println(appRunner.status());
  20.     break;
  21.    default:
  22.     throw new IllegalArgumentException("Unrecognized operation: " + op);
  23.   }
  24.  }
  25. }

代码示例来源：origin: org.apache.samza/samza-core_2.11

  1. public static void main(String[] args) throws Exception {
  2.   ApplicationRunnerCommandLine cmdLine = new ApplicationRunnerCommandLine();
  3.   OptionSet options = cmdLine.parser().parse(args);
  4.   Config orgConfig = cmdLine.loadConfig(options);
  5.   Config config = Util.rewriteConfig(orgConfig);
  6.   ApplicationRunnerOperation op = cmdLine.getOperation(options);
  8.   ApplicationRunner appRunner =
  9.     ApplicationRunners.getApplicationRunner(ApplicationUtil.fromConfig(config), config);
  11.   switch (op) {
  12.    case RUN:
  13.     appRunner.run();
  14.     break;
  15.    case KILL:
  16.     appRunner.kill();
  17.     break;
  18.    case STATUS:
  19.     System.out.println(appRunner.status());
  20.     break;
  21.    default:
  22.     throw new IllegalArgumentException("Unrecognized operation: " + op);
  23.   }
  24.  }
  25. }

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

  1. public static void main(String[] args) throws Exception {
  2.   ApplicationRunnerCommandLine cmdLine = new ApplicationRunnerCommandLine();
  3.   OptionSet options = cmdLine.parser().parse(args);
  4.   Config orgConfig = cmdLine.loadConfig(options);
  5.   Config config = Util.rewriteConfig(orgConfig);
  6.   ApplicationRunnerOperation op = cmdLine.getOperation(options);
  8.   ApplicationRunner appRunner =
  9.     ApplicationRunners.getApplicationRunner(ApplicationUtil.fromConfig(config), config);
  11.   switch (op) {
  12.    case RUN:
  13.     appRunner.run(null);
  14.     break;
  15.    case KILL:
  16.     appRunner.kill();
  17.     break;
  18.    case STATUS:
  19.     System.out.println(appRunner.status());
  20.     break;
  21.    default:
  22.     throw new IllegalArgumentException("Unrecognized operation: " + op);
  23.   }
  24.  }
  25. }

代码示例来源：origin: org.apache.samza/samza-core_2.12

  1. public static void main(String[] args) throws Exception {
  2.   ApplicationRunnerCommandLine cmdLine = new ApplicationRunnerCommandLine();
  3.   OptionSet options = cmdLine.parser().parse(args);
  4.   Config orgConfig = cmdLine.loadConfig(options);
  5.   Config config = Util.rewriteConfig(orgConfig);
  6.   ApplicationRunnerOperation op = cmdLine.getOperation(options);
  8.   ApplicationRunner appRunner =
  9.     ApplicationRunners.getApplicationRunner(ApplicationUtil.fromConfig(config), config);
  11.   switch (op) {
  12.    case RUN:
  13.     appRunner.run();
  14.     break;
  15.    case KILL:
  16.     appRunner.kill();
  17.     break;
  18.    case STATUS:
  19.     System.out.println(appRunner.status());
  20.     break;
  21.    default:
  22.     throw new IllegalArgumentException("Unrecognized operation: " + op);
  23.   }
  24.  }
  25. }

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

  1. public static void main(String[] args) throws Exception {
  2.   ApplicationRunnerCommandLine cmdLine = new ApplicationRunnerCommandLine();
  3.   OptionSet options = cmdLine.parser().parse(args);
  4.   Config orgConfig = cmdLine.loadConfig(options);
  5.   Config config = Util.rewriteConfig(orgConfig);
  6.   ApplicationRunnerOperation op = cmdLine.getOperation(options);
  8.   ApplicationRunner appRunner =
  9.     ApplicationRunners.getApplicationRunner(ApplicationUtil.fromConfig(config), config);
  11.   switch (op) {
  12.    case RUN:
  13.     appRunner.run();
  14.     break;
  15.    case KILL:
  16.     appRunner.kill();
  17.     break;
  18.    case STATUS:
  19.     System.out.println(appRunner.status());
  20.     break;
  21.    default:
  22.     throw new IllegalArgumentException("Unrecognized operation: " + op);
  23.   }
  24.  }
  25. }

内容来源于网络，如有侵权，请联系作者删除！

Util

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com