@Test public void getThrowsIfFunctionReturnsUnmappedValue() { assertThatThrownBy(() -> delegatingTransactionService.get(7L)) .isInstanceOf(IllegalStateException.class) .hasMessageContaining("Could not find a transaction service for timestamp {}"); }
@CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(keyedSyncServices, startTimestamp)); }
SplitKeyDelegatingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(keyedSyncServices, startTimestamp)); } }
SplitKeyDelegatingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(keyedSyncServices, startTimestamp)); } SplitKeyDelegatingTransactionService(
            Function<Long, T> timestampToServiceKey,
            Map<T, TransactionService> keyedServices); }
SplitKeyDelegatingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(keyedSyncServices, startTimestamp)); } SplitKeyDelegatingTransactionService(
            Function<Long, T> timestampToServiceKey,
            Map<T, TransactionService> keyedServices); @CheckForNull @Override Long get(long startTimestamp); @Override Map<Long, Long> get(Iterable<Long> startTimestamps); @Override ListenableFuture<Long> getAsync(long startTimestamp); @Override ListenableFuture<Map<Long, Long>> getAsync(Iterable<Long> startTimestamps); @Override void putUnlessExists(long startTimestamp, long commitTimestamp); @Override void close(); }
SplitKeyDelegatingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return AtlasFutures.getUnchecked(getInternal(keyedSyncServices, startTimestamp)); } SplitKeyDelegatingTransactionService(
            Function<Long, T> timestampToServiceKey,
            Map<T, TransactionService> keyedServices); @CheckForNull @Override Long get(long startTimestamp); @Override Map<Long, Long> get(Iterable<Long> startTimestamps); @Override ListenableFuture<Long> getAsync(long startTimestamp); @Override ListenableFuture<Map<Long, Long>> getAsync(Iterable<Long> startTimestamps); @Override void putUnlessExists(long startTimestamp, long commitTimestamp); @Override void close();  }