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

ZkJobCoordinatorMetrics.getMetricsRegistry介绍

暂无

代码示例

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

private void startMetrics() {
 for (MetricsReporter reporter: reporters.values()) {
  reporter.register("job-coordinator-" + processorId, (ReadableMetricsRegistry) metrics.getMetricsRegistry());
  reporter.start();
 }
}

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

private void startMetrics() {
 for (MetricsReporter reporter: reporters.values()) {
  reporter.register("job-coordinator-" + processorId, (ReadableMetricsRegistry) metrics.getMetricsRegistry());
  reporter.start();
 }
}

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

private void startMetrics() {
 for (MetricsReporter reporter: reporters.values()) {
  reporter.register("job-coordinator-" + processorId, (ReadableMetricsRegistry) metrics.getMetricsRegistry());
  reporter.start();
 }
}

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

private void startMetrics() {
 for (MetricsReporter reporter: reporters.values()) {
  reporter.register("job-coordinator-" + processorId, (ReadableMetricsRegistry) metrics.getMetricsRegistry());
  reporter.start();
 }
}

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

CheckpointManager checkpointManager = new TaskConfigJava(config).getCheckpointManager(metrics.getMetricsRegistry());
if (checkpointManager != null) {
 checkpointManager.createResources();

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

CheckpointManager checkpointManager = new TaskConfigJava(config).getCheckpointManager(metrics.getMetricsRegistry());
if (checkpointManager != null) {
 checkpointManager.createResources();

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

CheckpointManager checkpointManager = new TaskConfigJava(config).getCheckpointManager(metrics.getMetricsRegistry());
if (checkpointManager != null) {
 checkpointManager.createResources();

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

CheckpointManager checkpointManager = new TaskConfigJava(config).getCheckpointManager(metrics.getMetricsRegistry());
if (checkpointManager != null) {
 checkpointManager.createResources();

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

CheckpointManager checkpointManager = new TaskConfigJava(config).getCheckpointManager(metrics.getMetricsRegistry());
if (checkpointManager != null) {
 checkpointManager.createResources();

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

/**
 * Stores the configuration of the job in the coordinator stream.
 */
private void storeConfigInCoordinatorStream() {
 MetadataStore metadataStore = null;
 try {
  // Creates the coordinator stream if it does not exists.
  createCoordinatorStream();
  MetadataStoreFactory metadataStoreFactory = Util.getObj(new JobConfig(config).getMetadataStoreFactory(), MetadataStoreFactory.class);
  metadataStore = metadataStoreFactory.getMetadataStore(SetConfig.TYPE, config, metrics.getMetricsRegistry());
  metadataStore.init();
  CoordinatorStreamValueSerde jsonSerde = new CoordinatorStreamValueSerde(SetConfig.TYPE);
  for (Map.Entry<String, String> entry : config.entrySet()) {
   byte[] serializedValue = jsonSerde.toBytes(entry.getValue());
   metadataStore.put(entry.getKey(), serializedValue);
  }
 } finally {
  if (metadataStore != null) {
   LOG.info("Stopping the coordinator system producer.");
   metadataStore.close();
  }
 }
}

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

@VisibleForTesting
StreamPartitionCountMonitor getPartitionCountMonitor() {
 StreamMetadataCache streamMetadata = new StreamMetadataCache(systemAdmins, 0, SystemClock.instance());
 Set<SystemStream> inputStreamsToMonitor = new TaskConfigJava(config).getAllInputStreams();
 return new StreamPartitionCountMonitor(
     inputStreamsToMonitor,
     streamMetadata,
     metrics.getMetricsRegistry(),
     new JobConfig(config).getMonitorPartitionChangeFrequency(),
     streamsChanged -> {
   if (leaderElector.amILeader()) {
    debounceTimer.scheduleAfterDebounceTime(ON_PROCESSOR_CHANGE, 0, this::doOnProcessorChange);
   }
  });
}