@Test public void canReadInitialSweptTimestamp() { assertThat(progress.getLastSweptTimestamp(CONSERVATIVE_TEN)).isEqualTo(INITIAL_TIMESTAMP); }
public long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy) { return maybeGet(shardAndStrategy).orElse(SweepQueueUtils.INITIAL_TIMESTAMP); }
ShardProgress { public long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy) { return maybeGet(shardAndStrategy).orElse(SweepQueueUtils.INITIAL_TIMESTAMP); } }
ShardProgress { public long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy) { return maybeGet(shardAndStrategy).orElse(SweepQueueUtils.INITIAL_TIMESTAMP); } ShardProgress(KeyValueService kvs); }
ShardProgress { public long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy) { return maybeGet(shardAndStrategy).orElse(SweepQueueUtils.INITIAL_TIMESTAMP); } ShardProgress(KeyValueService kvs); int getNumberOfShards(); int updateNumberOfShards(int newNumber); long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy); long updateLastSweptTimestamp(ShardAndStrategy shardAndStrategy, long timestamp); }
ShardProgress { public long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy) { return maybeGet(shardAndStrategy).orElse(SweepQueueUtils.INITIAL_TIMESTAMP); } ShardProgress(KeyValueService kvs); int getNumberOfShards(); int updateNumberOfShards(int newNumber); long getLastSweptTimestamp(ShardAndStrategy shardAndStrategy); long updateLastSweptTimestamp(ShardAndStrategy shardAndStrategy, long timestamp);  }