@Test public void getRangeAtBoundThresholdWorksOnSingleRanges() { assertThat(manager.getRangeAtBoundThreshold( ValueAndBound.of(InternalSchemaMetadata.defaultValue(), TIMESTAMP_1)).getValue()) .isEqualTo(TransactionConstants.DIRECT_ENCODING_TRANSACTIONS_SCHEMA_VERSION); }
@VisibleForTesting Map.Entry<Range<Long>, Integer> getRangeAtBoundThreshold(ValueAndBound<InternalSchemaMetadata> valueAndBound) { return valueAndBound.value() .orElseThrow(() -> new SafeIllegalStateException("Unexpectedly found no value in store")) .timestampToTransactionsTableSchemaVersion() .rangeMapView() .getEntry(valueAndBound.bound()); }
TransactionSchemaManager { @VisibleForTesting Map.Entry<Range<Long>, Integer> getRangeAtBoundThreshold(ValueAndBound<InternalSchemaMetadata> valueAndBound) { return valueAndBound.value() .orElseThrow(() -> new SafeIllegalStateException("Unexpectedly found no value in store")) .timestampToTransactionsTableSchemaVersion() .rangeMapView() .getEntry(valueAndBound.bound()); } }
TransactionSchemaManager { @VisibleForTesting Map.Entry<Range<Long>, Integer> getRangeAtBoundThreshold(ValueAndBound<InternalSchemaMetadata> valueAndBound) { return valueAndBound.value() .orElseThrow(() -> new SafeIllegalStateException("Unexpectedly found no value in store")) .timestampToTransactionsTableSchemaVersion() .rangeMapView() .getEntry(valueAndBound.bound()); } TransactionSchemaManager(CoordinationService<InternalSchemaMetadata> coordinationService); }
TransactionSchemaManager { @VisibleForTesting Map.Entry<Range<Long>, Integer> getRangeAtBoundThreshold(ValueAndBound<InternalSchemaMetadata> valueAndBound) { return valueAndBound.value() .orElseThrow(() -> new SafeIllegalStateException("Unexpectedly found no value in store")) .timestampToTransactionsTableSchemaVersion() .rangeMapView() .getEntry(valueAndBound.bound()); } TransactionSchemaManager(CoordinationService<InternalSchemaMetadata> coordinationService); int getTransactionsSchemaVersion(long timestamp); boolean tryInstallNewTransactionsSchemaVersion(int newVersion); }
TransactionSchemaManager { @VisibleForTesting Map.Entry<Range<Long>, Integer> getRangeAtBoundThreshold(ValueAndBound<InternalSchemaMetadata> valueAndBound) { return valueAndBound.value() .orElseThrow(() -> new SafeIllegalStateException("Unexpectedly found no value in store")) .timestampToTransactionsTableSchemaVersion() .rangeMapView() .getEntry(valueAndBound.bound()); } TransactionSchemaManager(CoordinationService<InternalSchemaMetadata> coordinationService); int getTransactionsSchemaVersion(long timestamp); boolean tryInstallNewTransactionsSchemaVersion(int newVersion);  }