@Test public void canReadInitialNumberOfShards() { assertThat(progress.getNumberOfShards()).isEqualTo(AtlasDbConstants.DEFAULT_SWEEP_QUEUE_SHARDS); }
public int getNumberOfShards() { return maybeGet(SHARD_COUNT_SAS).map(Long::intValue).orElse(AtlasDbConstants.DEFAULT_SWEEP_QUEUE_SHARDS); }
ShardProgress { public int getNumberOfShards() { return maybeGet(SHARD_COUNT_SAS).map(Long::intValue).orElse(AtlasDbConstants.DEFAULT_SWEEP_QUEUE_SHARDS); } }
ShardProgress { public int getNumberOfShards() { return maybeGet(SHARD_COUNT_SAS).map(Long::intValue).orElse(AtlasDbConstants.DEFAULT_SWEEP_QUEUE_SHARDS); } ShardProgress(KeyValueService kvs); }
ShardProgress { public int getNumberOfShards() { return maybeGet(SHARD_COUNT_SAS).map(Long::intValue).orElse(AtlasDbConstants.DEFAULT_SWEEP_QUEUE_SHARDS); } ShardProgress(KeyValueService kvs); int getNumberOfShards(); int updateNumberOfShards(int newNumber); long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy); long updateLastSweptTimestamp(ShardAndStrategy shardAndStrategy, long timestamp); }
ShardProgress { public int getNumberOfShards() { return maybeGet(SHARD_COUNT_SAS).map(Long::intValue).orElse(AtlasDbConstants.DEFAULT_SWEEP_QUEUE_SHARDS); } ShardProgress(KeyValueService kvs); int getNumberOfShards(); int updateNumberOfShards(int newNumber); long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy); long updateLastSweptTimestamp(ShardAndStrategy shardAndStrategy, long timestamp);  }