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

TopologyContext.registerMetric介绍

暂无

代码示例

代码示例来源：origin: alibaba/jstorm

public <T extends IMetric> T registerMetric(String name, T metric, int timeBucketSizeInSecs) {
  return _topoContext.registerMetric(name, metric, timeBucketSizeInSecs);
}

代码示例来源：origin: alibaba/jstorm

public ReducedMetric registerMetric(String name, IReducer reducer, int timeBucketSizeInSecs) {
  return _topoContext.registerMetric(name, new ReducedMetric(reducer), timeBucketSizeInSecs);
}

代码示例来源：origin: alibaba/jstorm

public CombinedMetric registerMetric(String name, ICombiner combiner, int timeBucketSizeInSecs) {
  return registerMetric(name, new CombinedMetric(combiner), timeBucketSizeInSecs);
}

代码示例来源：origin: alibaba/jstorm

public ReducedMetric registerMetric(String name, IReducer reducer, int timeBucketSizeInSecs) {
  return registerMetric(name, new ReducedMetric(reducer), timeBucketSizeInSecs);
}

代码示例来源：origin: alibaba/jstorm

public CombinedMetric registerMetric(String name, ICombiner combiner, int timeBucketSizeInSecs) {
    return _topoContext.registerMetric(name, new CombinedMetric(combiner), timeBucketSizeInSecs);
  }
}

代码示例来源：origin: alibaba/jstorm

context.registerMetric("uptimeSecs", new IMetric() {
  @Override
  public Object getValueAndReset() {
context.registerMetric("startTimeSecs", new IMetric() {
  @Override
  public Object getValueAndReset() {
context.registerMetric("newWorkerEvent", new IMetric() {
  boolean doEvent = true;
context.registerMetric("memory/heap", new MemoryUsageMetric(new AFn() {
  public Object invoke() {
    return jvmMemRT.getHeapMemoryUsage();
context.registerMetric("memory/nonHeap", new MemoryUsageMetric(new AFn() {
  public Object invoke() {
    return jvmMemRT.getNonHeapMemoryUsage();
  context.registerMetric("GC/" + b.getName().replaceAll("\\W", ""), new GarbageCollectorMetric(b), bucketSize);

代码示例来源：origin: alibaba/jstorm

public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
  super.prepare(stormConf, context, collector);
  CountShellMetric cMetric = new CountShellMetric();
  context.registerMetric("my-custom-shell-metric", cMetric, 5);
}

代码示例来源：origin: alibaba/jstorm

@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
  super.open(conf, context, collector);
  CountShellMetric cMetric = new CountShellMetric();
  context.registerMetric("my-custom-shellspout-metric", cMetric, 5);
}

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

@SuppressWarnings("rawtypes")
 public CombinedMetric registerMetric(String name, ICombiner combiner, int timeBucketSizeInSecs) {
  return registerMetric(name, new CombinedMetric(combiner), timeBucketSizeInSecs);
 }
}

代码示例来源：origin: com.n3twork.storm/storm-core

public ReducedMetric registerMetric(String name, IReducer reducer, int timeBucketSizeInSecs) {
  return _topoContext.registerMetric(name, new ReducedMetric(reducer), timeBucketSizeInSecs);
}
public CombinedMetric registerMetric(String name, ICombiner combiner, int timeBucketSizeInSecs) {

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

@SuppressWarnings("rawtypes")
public ReducedMetric registerMetric(String name, IReducer reducer, int timeBucketSizeInSecs) {
 return registerMetric(name, new ReducedMetric(reducer), timeBucketSizeInSecs);
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

public ReducedMetric registerMetric(String name, IReducer reducer, int timeBucketSizeInSecs) {
  return registerMetric(name, new ReducedMetric(reducer), timeBucketSizeInSecs);
}

代码示例来源：origin: com.n3twork.storm/storm-core

public CombinedMetric registerMetric(String name, ICombiner combiner, int timeBucketSizeInSecs) {
    return registerMetric(name, new CombinedMetric(combiner), timeBucketSizeInSecs);
  }
}

代码示例来源：origin: wurstmeister/storm-kafka-0.8-plus

public TridentKafkaEmitter(Map conf, TopologyContext context, TridentKafkaConfig config, String topologyInstanceId) {
  _config = config;
  _topologyInstanceId = topologyInstanceId;
  _connections = new DynamicPartitionConnections(_config, KafkaUtils.makeBrokerReader(conf, _config));
  _topologyName = (String) conf.get(Config.TOPOLOGY_NAME);
  _kafkaOffsetMetric = new KafkaUtils.KafkaOffsetMetric(_config.topic, _connections);
  context.registerMetric("kafkaOffset", _kafkaOffsetMetric, _config.metricsTimeBucketSizeInSecs);
  _kafkaMeanFetchLatencyMetric = context.registerMetric("kafkaFetchAvg", new MeanReducer(), _config.metricsTimeBucketSizeInSecs);
  _kafkaMaxFetchLatencyMetric = context.registerMetric("kafkaFetchMax", new MaxMetric(), _config.metricsTimeBucketSizeInSecs);
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
  super.open(conf, context, collector);
  CountShellMetric cMetric = new CountShellMetric();
  context.registerMetric("my-custom-shellspout-metric", cMetric, 5);
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
  super.prepare(stormConf, context, collector);
  CountShellMetric cMetric = new CountShellMetric();
  context.registerMetric("my-custom-shell-metric", cMetric, 5);
}

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

public static AlertBolt createAlertBolt(OutputCollector collector) {
  Config config = ConfigFactory.load();
  PolicyGroupEvaluator policyGroupEvaluator = new PolicyGroupEvaluatorImpl("testPolicyGroupEvaluatorImpl");
  TestStreamRouterBolt.MockChangeService mockChangeService = new TestStreamRouterBolt.MockChangeService();
  AlertBolt bolt = new AlertBolt("alertBolt1", config, mockChangeService);
  Map stormConf = new HashMap<>();
  TopologyContext topologyContext = mock(TopologyContext.class);
  when(topologyContext.registerMetric(any(String.class), any(MultiCountMetric.class), any(int.class))).thenReturn(new MultiCountMetric());
  bolt.prepare(stormConf, topologyContext, collector);
  return bolt;
}

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

@Override
public void internalPrepare(OutputCollector collector, IMetadataChangeNotifyService metadataChangeNotifyService, Config config, TopologyContext context) {
  // instantiate output lock object
  outputLock = new Object();
  streamContext = new StreamContextImpl(config, context.registerMetric("eagle.evaluator", new MultiCountMetric(), 60), context);
  alertOutputCollector = new AlertBoltOutputCollectorWrapper(new StormOutputCollector(collector), outputLock, streamContext);
  policyGroupEvaluator.init(streamContext, alertOutputCollector);
  metadataChangeNotifyService.registerListener(this);
  metadataChangeNotifyService.init(config, MetadataType.ALERT_BOLT);
}

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

@Override
public void internalPrepare(OutputCollector collector, IMetadataChangeNotifyService changeNotifyService, Config config, TopologyContext context) {
  streamContext = new StreamContextImpl(config, context.registerMetric("eagle.router", new MultiCountMetric(), 60), context);
  routeCollector = new StreamRouterBoltOutputCollector(getBoltId(), new StormOutputCollector(collector, serializer), this.getOutputStreamIds(), streamContext);
  router.prepare(streamContext, routeCollector);
  changeNotifyService.registerListener(this);
  changeNotifyService.init(config, MetadataType.STREAM_ROUTER_BOLT);
}

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

@Override
public void internalPrepare(OutputCollector collector, IMetadataChangeNotifyService coordinatorService, Config config, TopologyContext context) {
  coordinatorService.registerListener(this);
  coordinatorService.init(config, MetadataType.ALERT_PUBLISH_BOLT);
  this.alertPublisher.init(config, stormConf);
  streamContext = new StreamContextImpl(config, context.registerMetric("eagle.publisher", new MultiCountMetric(), 60), context);
  this.context = context;
  this.alertTemplateEngine = AlertTemplateProvider.createAlertTemplateEngine();
  this.alertTemplateEngine.init(config);
  this.alertFilter = new PipeStreamFilter(new AlertContextEnrichFilter(this), new AlertTemplateFilter(alertTemplateEngine));
}