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

ZkTimestampSerializer.<init>介绍

暂无

代码示例

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

/** Provides a ZooKeeper-based IP black list. */
  @Provides @Singleton @BlackListIpValueStore
  MapStore<Long> provideBlackListIps(@Global CuratorFramework curator, LifeCycleRegistry lifeCycle) {
    CuratorFramework webCurator = withComponentNamespace(curator, "web");
    return lifeCycle.manage(new ZkMapStore<>(webCurator, "/blacklist", new ZkTimestampSerializer()));
  }
}

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

@Provides @Singleton @HintsConsistencyTimeValues
Map<String, ValueStore<Long>> provideHintsTimestampValues(@CassandraClusters Collection<String> cassandraClusters,
                             @GlobalFullConsistencyZooKeeper CuratorFramework curator,
                             LifeCycleRegistry lifeCycle)
    throws Exception {
  // Create a timestamp holder for each Cassandra cluster.
  Map<String, ValueStore<Long>> valuesByCluster = Maps.newLinkedHashMap();
  for (String cluster : cassandraClusters) {
    String zkPath = ZKPaths.makePath("/consistency/max-timestamp", cluster);
    ZkValueStore<Long> holder = new ZkValueStore<>(curator, zkPath, new ZkTimestampSerializer());
    valuesByCluster.put(cluster, lifeCycle.manage(holder));
  }
  return valuesByCluster;
}

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

@Provides @Singleton @HintsConsistencyTimeValues
Map<String, ValueStore<Long>> provideHintsTimestampValues(@CassandraClusters Collection<String> cassandraClusters,
                             @GlobalFullConsistencyZooKeeper CuratorFramework curator,
                             LifeCycleRegistry lifeCycle) {
  // Create a timestamp holder for each Cassandra cluster.
  Map<String, ValueStore<Long>> valuesByCluster = Maps.newLinkedHashMap();
  for (String cluster : cassandraClusters) {
    String zkPath = ZKPaths.makePath("/consistency/max-timestamp", cluster);
    ZkValueStore<Long> holder = new ZkValueStore<>(curator, zkPath, new ZkTimestampSerializer());
    valuesByCluster.put(cluster, lifeCycle.manage(holder));
  }
  return valuesByCluster;
}

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

@Provides @Singleton @HintsConsistencyTimeValues
Map<String, ValueStore<Long>> provideHintsTimestampValues(@CassandraClusters Collection<String> cassandraClusters,
                             @GlobalFullConsistencyZooKeeper CuratorFramework curator,
                             LifeCycleRegistry lifeCycle)
    throws Exception {
  // Create a timestamp holder for each Cassandra cluster.
  Map<String, ValueStore<Long>> valuesByCluster = Maps.newLinkedHashMap();
  for (String cluster : cassandraClusters) {
    String zkPath = ZKPaths.makePath("/consistency/max-timestamp", cluster);
    ZkValueStore<Long> holder = new ZkValueStore<>(curator, zkPath, new ZkTimestampSerializer());
    valuesByCluster.put(cluster, lifeCycle.manage(holder));
  }
  return valuesByCluster;
}

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

@Inject
public HintsConsistencyTimeTask(TaskRegistry taskRegistry, @Maintenance String scope,
                @GlobalFullConsistencyZooKeeper CuratorFramework curator,
                @HintsConsistencyTimeValues Map<String, ValueStore<Long>> timestampCache) {
  super(taskRegistry, scope + "-compaction-timestamp", "Full consistency maximum timestamp",
      timestampCache, curator, new ZkTimestampSerializer(),
      new Supplier<Long>() {
        @Override
        public Long get() {
          return HintsConsistencyTimeProvider.getDefaultTimestamp();
        }
      });
}

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

@Inject
public HintsConsistencyTimeTask(TaskRegistry taskRegistry, @Maintenance String scope,
                @GlobalFullConsistencyZooKeeper CuratorFramework curator,
                @HintsConsistencyTimeValues Map<String, ValueStore<Long>> timestampCache) {
  super(taskRegistry, scope + "-compaction-timestamp", "Full consistency maximum timestamp",
      timestampCache, curator, new ZkTimestampSerializer(),
      new Supplier<Long>() {
        @Override
        public Long get() {
          return HintsConsistencyTimeProvider.getDefaultTimestamp();
        }
      });
}