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

Config.registerMetricsConsumer介绍

暂无

代码示例

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

public static void registerMetricsConsumer(Map<String, Object> conf, Class klass) {
  registerMetricsConsumer(conf, klass, null, 1L);
}

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

public void registerMetricsConsumer(Class klass) {
  registerMetricsConsumer(this, klass);
}

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

public static void registerMetricsConsumer(Map<String, Object> conf, Class klass, long parallelismHint) {
  registerMetricsConsumer(conf, klass, null, parallelismHint);
}

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

public void registerMetricsConsumer(Class klass, Object argument, long parallelismHint) {
  registerMetricsConsumer(this, klass, argument, parallelismHint);
}

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

public void registerMetricsConsumer(Class klass, long parallelismHint) {
  registerMetricsConsumer(this, klass, parallelismHint);
}

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

conf.registerMetricsConsumer(LoggingMetricsConsumer.class);
conf.registerMetricsConsumer(HttpForwardingMetricsConsumer.class, url, 1);
Map<String, String> workerMetrics = new HashMap<>();
if (!NimbusClient.isLocalOverride()) {

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

conf.registerMetricsConsumer(LoggingMetricsConsumer.class);
conf.registerMetricsConsumer(HttpForwardingMetricsConsumer.class, url, 1);
Map<String, String> workerMetrics = new HashMap<>();
if (!NimbusClient.isLocalOverride()) {

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

conf.setMaxTaskParallelism(1);
conf.setDebug(true);
conf.registerMetricsConsumer(LoggingMetricsConsumer.class);

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

public static void main(String[] args) throws Exception {
  TopologyBuilder builder = new TopologyBuilder();
  builder.setSpout("spout", new InOrderSpout(), 8);
  builder.setBolt("count", new Check(), 8).fieldsGrouping("spout", new Fields("c1"));
  Config conf = new Config();
  conf.registerMetricsConsumer(org.apache.storm.metric.LoggingMetricsConsumer.class);
  String name = "in-order-test";
  if (args != null && args.length > 0) {
    name = args[0];
  }
  conf.setNumWorkers(1);
  StormSubmitter.submitTopologyWithProgressBar(name, conf, builder.createTopology());
  Map<String, Object> clusterConf = Utils.readStormConfig();
  clusterConf.putAll(Utils.readCommandLineOpts());
  Nimbus.Iface client = NimbusClient.getConfiguredClient(clusterConf).getClient();
  //Sleep for 50 mins
  for (int i = 0; i < 50; i++) {
    Thread.sleep(30 * 1000);
    printMetrics(client, name);
  }
  kill(client, name);
}

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

public static void main(String[] args) throws Exception {
  TopologyBuilder builder = new TopologyBuilder();
  builder.setSpout("spout", new FastRandomSentenceSpout(), 4);
  builder.setBolt("split", new SplitSentence(), 4).shuffleGrouping("spout");
  builder.setBolt("count", new WordCount(), 4).fieldsGrouping("split", new Fields("word"));
  Config conf = new Config();
  conf.registerMetricsConsumer(org.apache.storm.metric.LoggingMetricsConsumer.class);
  String name = "wc-test";
  if (args != null && args.length > 0) {
    name = args[0];
  }
  conf.setNumWorkers(1);
  StormSubmitter.submitTopologyWithProgressBar(name, conf, builder.createTopology());
  Map<String, Object> clusterConf = Utils.readStormConfig();
  clusterConf.putAll(Utils.readCommandLineOpts());
  Nimbus.Iface client = NimbusClient.getConfiguredClient(clusterConf).getClient();
  //Sleep for 5 mins
  for (int i = 0; i < 10; i++) {
    Thread.sleep(30 * 1000);
    printMetrics(client, name);
  }
  kill(client, name);
}

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

public static void registerMetricsConsumer(Map conf, Class klass, long parallelismHint) {
  registerMetricsConsumer(conf, klass, null, parallelismHint);
}

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

public void registerMetricsConsumer(Class klass, long parallelismHint) {
  registerMetricsConsumer(this, klass, parallelismHint);
}

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

public static void registerMetricsConsumer(Map conf, Class klass) {
  registerMetricsConsumer(conf, klass, null, 1L);
}

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

public void registerMetricsConsumer(Class klass) {
  registerMetricsConsumer(this, klass);
}

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

public void registerMetricsConsumer(Class klass, Object argument, long parallelismHint) {
  registerMetricsConsumer(this, klass, argument, parallelismHint);
}

代码示例来源：origin: com.twitter.heron/heron-storm

public void registerMetricsConsumer(Class klass, long parallelismHint) {
 registerMetricsConsumer(klass, null, parallelismHint);
}

代码示例来源：origin: com.twitter.heron/heron-storm

public void registerMetricsConsumer(Class klass) {
 registerMetricsConsumer(klass, null, 1L);
}

代码示例来源：origin: com.yahoo.bullet/bullet-storm

/**
   * Registers the Sigar CPUMetric and the LoggingMetricsConsumer with a parallelism of 1.
   *
   * @param stormConfig The Storm {@link Config} to add to.
   * @param bulletStormConfig The Bullet {@link BulletStormConfig} to get information from.
   */
  public static void register(Config stormConfig, BulletStormConfig bulletStormConfig) {
    stormConfig.registerMetricsConsumer(LoggingMetricsConsumer.class);
    Map<String, String> metrics = (Map<String, String>) stormConfig.getOrDefault(Config.TOPOLOGY_WORKER_METRICS, new HashMap<>());
    metrics.putAll(METRICS);
    stormConfig.put(Config.TOPOLOGY_WORKER_METRICS, metrics);
  }
}

代码示例来源：origin: bullet-db/bullet-storm

/**
   * Registers the Sigar CPUMetric and the LoggingMetricsConsumer with a parallelism of 1.
   *
   * @param stormConfig The Storm {@link Config} to add to.
   * @param bulletStormConfig The Bullet {@link BulletStormConfig} to get information from.
   */
  public static void register(Config stormConfig, BulletStormConfig bulletStormConfig) {
    stormConfig.registerMetricsConsumer(LoggingMetricsConsumer.class);
    Map<String, String> metrics = (Map<String, String>) stormConfig.getOrDefault(Config.TOPOLOGY_WORKER_METRICS, new HashMap<>());
    metrics.putAll(METRICS);
    stormConfig.put(Config.TOPOLOGY_WORKER_METRICS, metrics);
  }
}

代码示例来源：origin: bullet-db/bullet-storm

public static void register(Config stormConfig, BulletStormConfig bulletStormConfig) {
    bulletStormConfig.set(CUSTOM_METRICS_REGISTERED, true);
    stormConfig.registerMetricsConsumer(CustomIMetricsConsumer.class);
  }
}