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

ZkDurationSerializer介绍

[英]Formats a duration in ZooKeeper as a human-readable ISO-8601 string for transparency, easy debugging.
[中]将ZooKeeper中的持续时间格式化为人类可读的ISO-8601字符串，以便透明、易于调试。

代码示例

代码示例来源：origin: bazaarvoice/emodb

@Inject
public MinLagDurationTask(TaskRegistry taskRegistry,
             @Maintenance String scope,
             @GlobalFullConsistencyZooKeeper CuratorFramework curator,
             @MinLagDurationValues Map<String, ValueStore<Duration>> durationCache) {
  super(taskRegistry, scope + "-compaction-lag", "Full consistency minimum lag",
      durationCache, curator, new ZkDurationSerializer(),
      Suppliers.ofInstance(MinLagConsistencyTimeProvider.DEFAULT_LAG));
}

代码示例来源：origin: bazaarvoice/emodb

expiryDuration = new ZkDurationSerializer().fromString(durationString);

代码示例来源：origin: bazaarvoice/emodb

Collection<String> values = parameters.get("duration");
if (values.size() == 1) {
  expiryDuration = new ZkDurationSerializer().fromString(values.iterator().next());
} else if (values.size() > 1) {
  throw new IllegalArgumentException("At most one duration parameter is permitted");

代码示例来源：origin: com.bazaarvoice.emodb/emodb-table

@Inject
public MinLagDurationTask(TaskRegistry taskRegistry,
             @Maintenance String scope,
             @GlobalFullConsistencyZooKeeper CuratorFramework curator,
             @MinLagDurationValues Map<String, ValueStore<Duration>> durationCache) {
  super(taskRegistry, scope + "-compaction-lag", "Full consistency minimum lag",
      durationCache, curator, new ZkDurationSerializer(),
      Suppliers.ofInstance(MinLagConsistencyTimeProvider.DEFAULT_LAG));
}

代码示例来源：origin: bazaarvoice/emodb

expiryDuration = new ZkDurationSerializer().fromString(string);

代码示例来源：origin: com.bazaarvoice.emodb/emodb-sor

@Provides @Singleton @MinLagDurationValues
Map<String, ValueStore<Duration>> provideMinLagDurationValues(@CassandraClusters Collection<String> cassandraClusters,
                               @GlobalFullConsistencyZooKeeper final CuratorFramework curator,
                               final LifeCycleRegistry lifeCycle) {
  final ConcurrentMap<String, ValueStore<Duration>> valuesByCluster = Maps.newConcurrentMap();
  for (String cluster : cassandraClusters) {
    String zkPath = ZKPaths.makePath("/consistency/min-lag", cluster);
    ZkValueStore<Duration> holder = new ZkValueStore<>(curator, zkPath, new ZkDurationSerializer());
    valuesByCluster.put(cluster, lifeCycle.manage(holder));
  }
  return valuesByCluster;
}

代码示例来源：origin: bazaarvoice/emodb

@Provides @Singleton @MinLagDurationValues
Map<String, ValueStore<Duration>> provideMinLagDurationValues(@CassandraClusters Collection<String> cassandraClusters,
                               @GlobalFullConsistencyZooKeeper final CuratorFramework curator,
                               final LifeCycleRegistry lifeCycle) {
  final ConcurrentMap<String, ValueStore<Duration>> valuesByCluster = Maps.newConcurrentMap();
  for (String cluster : cassandraClusters) {
    String zkPath = ZKPaths.makePath("/consistency/min-lag", cluster);
    ZkValueStore<Duration> holder = new ZkValueStore<>(curator, zkPath, new ZkDurationSerializer());
    valuesByCluster.put(cluster, lifeCycle.manage(holder));
  }
  return valuesByCluster;
}

代码示例来源：origin: bazaarvoice/emodb

@Provides @Singleton @MinLagDurationValues
Map<String, ValueStore<Duration>> provideMinLagDurationValues(@CassandraClusters Collection<String> cassandraClusters,
                               @GlobalFullConsistencyZooKeeper final CuratorFramework curator,
                               final LifeCycleRegistry lifeCycle) {
  final ConcurrentMap<String, ValueStore<Duration>> valuesByCluster = Maps.newConcurrentMap();
  for (String cluster : cassandraClusters) {
    String zkPath = ZKPaths.makePath("/consistency/min-lag", cluster);
    ZkValueStore<Duration> holder = new ZkValueStore<>(curator, zkPath, new ZkDurationSerializer());
    valuesByCluster.put(cluster, lifeCycle.manage(holder));
  }
  return valuesByCluster;
}