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

Transaction.getRanges介绍

[英]Creates a visitable that scans the provided range.

To get good performance out of this method, it is important to specify the batch hint in each RangeRequest. If this isn't done then this method may do more work than you need and will be slower than it needs to be. If the batchHint isn't specified it will default to 1 for the first page in each range.
[中]创建扫描所提供范围的可见表。
为了获得良好的性能，在每个RangeRequest中指定批处理提示是很重要的。如果不这样做，那么这个方法可能会做比你需要的更多的工作，并且会比需要的慢。如果未指定batchHint，则每个范围的第一页默认为1。

代码示例

代码示例来源：origin: palantir/atlasdb

@Override
public <T> Stream<T> getRanges(
    final TableReference tableRef,
    Iterable<RangeRequest> rangeRequests,
    BiFunction<RangeRequest, BatchingVisitable<RowResult<byte[]>>, T> visitableProcessor) {
  return delegate().getRanges(tableRef, rangeRequests, visitableProcessor);
}

代码示例来源：origin: palantir/atlasdb

private void verifyAllGetRangesImplsNumRanges(Transaction t, Iterable<RangeRequest> rangeRequests, List<String> expectedValues) {
  Iterable<BatchingVisitable<RowResult<byte[]>>> getRangesWithPrefetchingImpl =
      t.getRanges(TEST_TABLE, rangeRequests);
  Iterable<BatchingVisitable<RowResult<byte[]>>> getRangesInParallelImpl =
      t.getRanges(TEST_TABLE, rangeRequests, 2, (rangeRequest, visitable) -> visitable).collect(Collectors.toList());
  Iterable<BatchingVisitable<RowResult<byte[]>>> getRangesLazyImpl =
      t.getRangesLazy(TEST_TABLE, rangeRequests).collect(Collectors.toList());
  assertEquals(expectedValues, extractStringsFromVisitables(getRangesWithPrefetchingImpl));
  assertEquals(expectedValues, extractStringsFromVisitables(getRangesInParallelImpl));
  assertEquals(expectedValues, extractStringsFromVisitables(getRangesLazyImpl));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<SweepPriorityRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, SweepPriorityRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<MetadataRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, MetadataRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<CreatedIdxRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, CreatedIdxRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<KvDynamicColumnsRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, KvDynamicColumnsRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<KeyValueRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, KeyValueRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                BiFunction<RangeRequest, BatchingVisitable<SweepPriorityRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, SweepPriorityRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                BiFunction<RangeRequest, BatchingVisitable<KvDynamicColumnsRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, KvDynamicColumnsRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<CookiesIdxRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, CookiesIdxRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<KvRowsRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, KvRowsRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                BiFunction<RangeRequest, BatchingVisitable<MetadataRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, MetadataRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

@Override
public <T> Stream<T> getRanges(
    final TableReference tableRef,
    Iterable<RangeRequest> rangeRequests,
    int concurrencyLevel,
    BiFunction<RangeRequest, BatchingVisitable<RowResult<byte[]>>, T> visitableProcessor) {
  checkTableName(tableRef);
  return delegate().getRanges(tableRef, rangeRequests, concurrencyLevel, visitableProcessor);
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<GenericRangeScanTestRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, GenericRangeScanTestRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                BiFunction<RangeRequest, BatchingVisitable<RangeScanTestRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, RangeScanTestRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<Index2IdxRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, Index2IdxRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                BiFunction<RangeRequest, BatchingVisitable<GenericRangeScanTestRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, GenericRangeScanTestRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<Index3IdxRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, Index3IdxRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                int concurrencyLevel,
                BiFunction<RangeRequest, BatchingVisitable<Index4IdxRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges, concurrencyLevel,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, Index4IdxRowResult::of)));
}

代码示例来源：origin: palantir/atlasdb

public <T> Stream<T> getRanges(Iterable<RangeRequest> ranges,
                BiFunction<RangeRequest, BatchingVisitable<Index4IdxRowResult>, T> visitableProcessor) {
  return t.getRanges(tableRef, ranges,
      (rangeRequest, visitable) -> visitableProcessor.apply(rangeRequest, BatchingVisitables.transform(visitable, Index4IdxRowResult::of)));
}